Documentation
¶
Index ¶
- func Error[T any](err error) iter.Seq2[T, error]
- func Filter[T any](stream iter.Seq2[T, error], predicate func(T) bool) iter.Seq2[T, error]
- func Just[T any](values ...T) iter.Seq2[T, error]
- func Map[T, R any](stream iter.Seq2[T, error], mapper func(T) (R, error)) iter.Seq2[R, error]
- func Merge[T any](streams ...iter.Seq2[T, error]) iter.Seq2[T, error]
- func Observe[T any](stream iter.Seq2[T, error], observer func(T, error) error) iter.Seq2[T, error]
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Filter ¶
Filter returns a iter.Seq2 that emits only the values from the input stream that satisfy the given predicate function.
func Map ¶
Map returns a iter.Seq2 that emits the results of applying the given mapper function to each value from the input stream.
func Merge ¶
Merge takes multiple input streams (as iter.Seq2) and merges their outputs into a single output stream.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.