stdlibx.streams.fn.base module¶
- stdlibx.streams.fn.base.as_tuple()[source]¶
- Return type:
Operation[Observable[T], Observable[tuple[T]]]
- stdlibx.streams.fn.base.combine(other)[source]¶
- Parameters:
other (Observable[U])
- Return type:
Operation[Observable[tuple[Unpack[Ts]]], Observable[tuple[Unpack[Ts], U]]]
- stdlibx.streams.fn.base.distinct(equal_fn=<built-in function eq>)[source]¶
- Parameters:
equal_fn (Callable[[T, T], bool])
- Return type:
Operation[Observable[T], Observable[T]]
- stdlibx.streams.fn.base.for_(func)[source]¶
- Parameters:
func (Callable[[T], U])
- Return type:
Operation[Observable[Iterable[T]], Observable[Iterable[U]]]
- stdlibx.streams.fn.base.if_(func)[source]¶
- Parameters:
func (Callable[[T], bool])
- Return type:
Operation[Observable[T], Observable[T]]
- stdlibx.streams.fn.base.is_(func)[source]¶
- Parameters:
func (Callable[[Union[T, U]], TypeGuard[U]])
- Return type:
Operation[Observable[Union[T, U]], Observable[U]]
- stdlibx.streams.fn.base.is_not_none()[source]¶
- Return type:
Operation[Observable[Union[T, None]], Observable[T]]
- stdlibx.streams.fn.base.map_(func)[source]¶
- Parameters:
func (Callable[[T], U])
- Return type:
Operation[Observable[T], Observable[U]]
- stdlibx.streams.fn.base.start_with(value)[source]¶
- Parameters:
value (T)
- Return type:
Operation[Observable[T], Observable[T]]