callback

May 15, 2025

Changes in this version

+ type BatchStreamOnce struct

+ func (b *BatchStreamOnce[T]) OnComplete(err error)

+ func (b *BatchStreamOnce[T]) OnNext(t T) 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 *entities.TWithError[T]) StreamCallback[T]

Feb 26, 2025

Changes in this version

+ type Callback interface

+ Complete func(t T)

+ CompleteError func(err error)

+ func NewOnce[T any](onComplete func(t T), onError func(err error)) Callback[T]

+ type Once struct

+ OnComplete func(t T)

+ OnCompleteError func(err error)

+ func (c *Once[T]) Complete(t T)

+ func (c *Once[T]) CompleteError(err error)