Documentation
¶
Index ¶
- func FromChan[T any](ctx context.Context, in <-chan T) iter.Seq[T]
- func FromChans[T any](ctx context.Context, ins []<-chan T) []iter.Seq[T]
- func Shards[IN, OUT any](ctx context.Context, ins []iter.Seq[IN], handler gather.HandlerFunc[IN, OUT], ...) []iter.Seq[OUT]
- func ToChan[T any](ctx context.Context, in iter.Seq[T], buffer int) <-chan T
- func ToChans[T any](ctx context.Context, ins []iter.Seq[T], buffer int) []<-chan T
- func Workers[IN, OUT any](ctx context.Context, in iter.Seq[IN], handler gather.HandlerFunc[IN, OUT], ...) iter.Seq[OUT]
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Shards ¶
func Shards[IN, OUT any]( ctx context.Context, ins []iter.Seq[IN], handler gather.HandlerFunc[IN, OUT], buffer int, workerOpts ...gather.Opt, ) []iter.Seq[OUT]
Shards - integrates shard.Apply using iter.Seq in place of channels by default, shards will use the same buffer as the input
func Workers ¶
func Workers[IN, OUT any]( ctx context.Context, in iter.Seq[IN], handler gather.HandlerFunc[IN, OUT], buffer int, workerOpts ...gather.Opt, ) iter.Seq[OUT]
Workers - integrates with gather.Workers using iter.Seq in place of channels by default, the workers will use the same buffer as the input
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.