in internal/routing/routing.go [86:99]
func (b *Batches) Register(ctx context.Context, name string, ch chan batching.Batches) error {
if b.started {
return fmt.Errorf("routing.Batches.Register: cannot Register a route after Start() is called")
}
if name == "" {
return fmt.Errorf("routing.Batches.Register; cannot Register a route with an empty name")
}
if ch == nil {
return fmt.Errorf("routing.Batches.Register: cannot Register a route with a nil channel")
}
b.routes = append(b.routes, route{name: name, out: ch})
return nil
}