Versions in this module Expand all Collapse all v0 v0.1.1 Jul 8, 2026 v0.1.0 Jul 8, 2026 Changes in this version + 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]