stdlibx.streams.methods package

stdlibx.streams.methods.as_tuple(source)[source]
Parameters:

source (Observable[T])

Return type:

Observable[tuple[T]]

stdlibx.streams.methods.combine(source, other)[source]
Parameters:
Return type:

Observable[tuple[Unpack[Ts], U]]

stdlibx.streams.methods.distinct(source, equal_fn=<built-in function eq>)[source]
Parameters:

  • source (Observable[T])

  • equal_fn (Callable[[T, T], bool])

Return type:

Observable[T]

stdlibx.streams.methods.for_(source, func)[source]
Parameters:

  • source (Observable[Iterable[T]])

  • func (Callable[[T], U])

Return type:

Observable[Iterable[U]]

stdlibx.streams.methods.if_(source, func)[source]
Parameters:

  • source (Observable[T])

  • func (Callable[[T], bool])

Return type:

Observable[T]

stdlibx.streams.methods.is_(source, func)[source]
Parameters:

  • source (Observable[Union[T, U]])

  • func (Callable[[Union[T, U]], TypeGuard[U]])

Return type:

Observable[U]

stdlibx.streams.methods.is_not_none(source)[source]
Parameters:

source (Observable[Union[T, None]])

Return type:

Observable[T]

stdlibx.streams.methods.map_(source, func)[source]
Parameters:
Return type:

Observable[U]

stdlibx.streams.methods.start_with(source, value)[source]
Parameters:
Return type:

Observable[T]

Submodules