Versions in this module Expand all Collapse all v1 v1.0.0 Nov 9, 2022 Changes in this version + func DrainStream(ctx context.Context, producer Producer[T], consumer Consumer[T], ...) error + func WithStreamMode(ctx context.Context, mode StreamMode) context.Context + type Consumer func(ctx context.Context, entity T) error + type Finisher func(ctx context.Context) error + type Producer func(ctx context.Context, stream chan T) error + type StreamMode int + const Exhaustible + const Infinite Other modules containing this package codeberg.org/apapsch/go-streaming-channel/v2
Go to main page