Stream
Public Python members of Stream.
Generated from the pinned SDK source. Use the matching installation. Each source link points to this baseline.
Methods decorated with @fn return effects. Their implementation signatures use EffectGen for the generator body. Compose them with yield from inside a scoped workflow.
map
def map[B](self, transform: Callable[[A], B]) -> Stream[B, E, R]filter
def filter(self, predicate: Callable[[A], bool]) -> Stream[A, E, R]:
@genmap_effect
def map_effect[B, E2 = Never, R2 = Never](
self, transform: Callable[[A], Effect[B, E2, R2]]
) -> Stream[B, E | E2, R | R2]:
@gentap
def tap[E2 = Never, R2 = Never](
self, action: Callable[[A], Effect[object, E2, R2]]
) -> Stream[A, E | E2, R | R2]:
@gentake
def take(self, count: int) -> Stream[A, E, R]:
@genrun_fold
def run_fold[B](self, initial: B, combine: Callable[[B, A], B]) -> Effect[B, E, R]:
@genmerge
@staticmethod
def merge[A2, E2 = Never, R2 = Never](
*streams: Stream[A2, E2, R2], buffer_size: int = 64
) -> Stream[A2, E2, R2]:
@genrun_collect
def run_collect(self) -> Effect[tuple[A, ...], E, R]:
@genrun_for_each
def run_for_each[E2 = Never, R2 = Never](
self, action: Callable[[A], Effect[object, E2, R2]]
) -> Effect[None, E | E2, R | R2]:
@genrun_drain
def run_drain(self) -> Effect[None, E, R]run_head
def run_head(self) -> Effect[A | None, E, R]unwrap
@staticmethod
def unwrap[A2, E2 = Never, R2 = Never](
effect: Effect[Stream[A2, E2, R2], E2, R2],
) -> Stream[A2, E2, R2]How is this page?
Last updated on