generics_channel.go

func (r *Runner) Start(handler func([T]), channel chan [T]) {
    go func() {
      for {
        select {
        case i := <-runner.Interrupt:
          return
        case msg := <-channel
          handler(msg)
        }
      }
    }()
  }
}