Versions in this module Expand all Collapse all v0 v0.13.2 Jun 13, 2025 v0.13.1 May 30, 2025 Changes in this version + func WaitUntilSignal(closers ...io.Closer) + type BatchStreamOnce struct + func (b *BatchStreamOnce[T]) OnComplete(err error) + func (b *BatchStreamOnce[T]) OnNext(t T) error + type Callback interface + OnComplete func(t T) + OnCompleteError func(err error) + func NewOnce[T any](onComplete func(t T), onError func(err error)) Callback[T] + type ConditionContext interface + Broadcast func() + Signal func() + Wait func(ctx context.Context) error + func NewConditionContext(locker sync.Locker) ConditionContext + type Future interface + Complete func(result T) + Fail func(err error) + Wait func(ctx context.Context) (T, error) + func NewFuture[T any]() Future[T] + type Once struct + func (c *Once[T]) OnComplete(t T) + func (c *Once[T]) OnCompleteError(err error) + type Stream struct + func (s *Stream[T]) OnComplete(err error) + func (s *Stream[T]) OnNext(element T) error + type StreamCallback interface + OnComplete func(err error) + OnNext func(t T) error + func NewBatchStreamOnce[T any](maxBatchCount int, maxBatchBytes int, getBytes func(T) int, ...) StreamCallback[T] + func NewStreamOnce[T any](callback StreamCallback[T]) StreamCallback[T] + func ReadFromStreamCallback[T any](ch chan *entity.TWithError[T]) StreamCallback[T] + type WaitGroup interface + Done func() + Fail func(err error) + Wait func(ctx context.Context) error + func NewWaitGroup(parties int) WaitGroup
Go to main page