chanx

Oct 7, 2024

Changes in this version

+ func Insert[T any](ch chan<- T, value T) bool

+ type Stream struct

+ func NewWithBuffer[T any](count, buffer int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]

+ func New[T any](count int, consumer func(ctx context.Context, channel chan T) error) *Stream[T]

+ func (v *Stream[T]) Close()

+ func (v *Stream[T]) Push(item T) bool

+ func (v *Stream[T]) StartSteaming(ctx context.Context) error