func()

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
}