cstream

Apr 14, 2024

Changes in this version

+ type Map struct

+ func NewMap[I, O any](ctx context.Context, goroutine int, input []I, ...) *Map[I, O]

+ func (m *Map[I, O]) Close()

+ func (m *Map[I, O]) IsDone() bool

+ func (m *Map[I, O]) IsRunning() bool

+ func (m *Map[I, O]) Result(ctx context.Context) ([]O, error)

+ func (m *Map[I, O]) Wait() error

type Stream

+ func (s *Stream[T]) IsDone() bool

+ func (s *Stream[T]) IsRunning() bool

Apr 13, 2024

Changes in this version

+ type ParallelMap struct

+ func NewParallelMap[I, O any](ctx context.Context, c int, input []I, iteratee func(item I, index int) O) ParallelMap[I, O]

+ func (p *ParallelMap[I, O]) Result(ctx context.Context) ([]O, error)

+ func (p *ParallelMap[I, O]) Wait() error

+ func (s *ParallelMap[I, O]) Close()

+ type Stream struct

+ func NewStream[T any](ctx context.Context, c int, out chan T) *Stream[T]

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

+ func (s *Stream[T]) Go(task func() T)

+ func (s *Stream[T]) Out() <-chan T

+ func (s *Stream[T]) Wait() error