callback

type BatchStreamOnce[T any] struct {
	// contains filtered or unexported fields
}

type Callback[T any] interface {
	// Complete is invoked when the operation completes successfully with the result 't' of type T.
	Complete(t T)

	// CompleteError is invoked when the operation fails, providing an error 'err' indicating the failure reason.
	CompleteError(err error)
}

type Once[T any] struct {
	OnComplete      func(t T)       // Callback function called on successful completion
	OnCompleteError func(err error) // Callback function called when an error occurs
	// contains filtered or unexported fields
}

type Stream[T any] struct {
	// contains filtered or unexported fields
}

type StreamCallback[T any] interface {

	// OnNext is called whenever a new data item of type T is received from the stream.
	// It processes the received data item and returns an error if any issues occur during processing.
	// This method allows for custom logic to be applied to each individual data item in the stream.
	OnNext(t T) error

	// OnComplete is called when the stream has ended, either successfully or due to an error.
	// The 'err' parameter indicates the status of the stream completion.
	// If the stream ended successfully, 'err' will be nil. Otherwise,
	// it will contain the error that caused the stream to terminate.
	OnComplete(err error)
}