Documentation
¶
Index ¶
- func BrokenSinkError() error
- type ChanElem
- type StreamingChan
- func CreateChannel[T any](generator func(sink func(data T, context context.Context) bool) error) StreamingChan[T]
- func CreateChannelBuffered[T any](bufSize int, ...) StreamingChan[T]
- func FlapMap[P any, Q any](ch StreamingChan[P], mapper func(data P) StreamingChan[Q]) StreamingChan[Q]
- func Map[P any, Q any](ch StreamingChan[P], mapper func(data P) Q) StreamingChan[Q]
- func SingleElemChannel[T any](data T) StreamingChan[T]
- func SingleElemChannelErr[T any](data T, err error) StreamingChan[T]
- func SliceToChannel[T any](data []T) StreamingChan[T]
- func (ch StreamingChan[T]) CollectToSlice() ([]T, error)
- func (ch StreamingChan[T]) FlatMap(mapper func(data T) StreamingChan[any]) StreamingChan[any]
- func (ch StreamingChan[T]) ForEachChanElem(onEach func(data T) error) error
- func (ch StreamingChan[T]) Map(mapper func(data T) any) StreamingChan[any]
- func (ch StreamingChan[T]) ToChan(outBufSize int) (outCh chan<- T, errCh chan<- error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BrokenSinkError ¶
func BrokenSinkError() error
Types ¶
type ChanElem ¶
type ChanElem[T any] struct { // contains filtered or unexported fields }
func WrapChanData ¶
func WrapChanErr ¶
type StreamingChan ¶
func CreateChannel ¶
func CreateChannelBuffered ¶
func FlapMap ¶
func FlapMap[P any, Q any](ch StreamingChan[P], mapper func(data P) StreamingChan[Q]) StreamingChan[Q]
func Map ¶
func Map[P any, Q any](ch StreamingChan[P], mapper func(data P) Q) StreamingChan[Q]
func SingleElemChannel ¶
func SingleElemChannel[T any](data T) StreamingChan[T]
func SingleElemChannelErr ¶
func SingleElemChannelErr[T any](data T, err error) StreamingChan[T]
func SliceToChannel ¶
func SliceToChannel[T any](data []T) StreamingChan[T]
func (StreamingChan[T]) CollectToSlice ¶
func (ch StreamingChan[T]) CollectToSlice() ([]T, error)
func (StreamingChan[T]) FlatMap ¶
func (ch StreamingChan[T]) FlatMap(mapper func(data T) StreamingChan[any]) StreamingChan[any]
func (StreamingChan[T]) ForEachChanElem ¶
func (ch StreamingChan[T]) ForEachChanElem(onEach func(data T) error) error
func (StreamingChan[T]) Map ¶
func (ch StreamingChan[T]) Map(mapper func(data T) any) StreamingChan[any]
func (StreamingChan[T]) ToChan ¶ added in v0.11.7
func (ch StreamingChan[T]) ToChan(outBufSize int) (outCh chan<- T, errCh chan<- error)
Source Files
Click to show internal directories.
Click to hide internal directories.