Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrStreamerClosed = errors.New("stream closed")
Functions ¶
This section is empty.
Types ¶
type StreamWaitFn ¶
type StreamWaitFn func() error
StreamWaitFn is a method used to wait for a stream to end, catching any error in the process.
func NewStreamer ¶
func NewStreamer[Data any](ctx context.Context, callback StreamerCallback[Data]) (<-chan Data, StreamWaitFn)
Source Files
Click to show internal directories.
Click to hide internal directories.