stdlibx.streams.methods.base module¶
- stdlibx.streams.methods.base.as_tuple(source)[source]¶
- Parameters:
source (Observable[T])
- Return type:
Observable[tuple[T]]
- stdlibx.streams.methods.base.combine(source, other)[source]¶
- Parameters:
source (Observable[tuple[Unpack[Ts]]])
other (Observable[U])
- Return type:
Observable[tuple[Unpack[Ts], U]]
- stdlibx.streams.methods.base.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.base.for_(source, func)[source]¶
- Parameters:
source (Observable[Iterable[T]])
func (Callable[[T], U])
- Return type:
Observable[Iterable[U]]
- stdlibx.streams.methods.base.if_(source, func)[source]¶
- Parameters:
source (Observable[T])
func (Callable[[T], bool])
- Return type:
Observable[T]
- stdlibx.streams.methods.base.is_(source, func)[source]¶
- Parameters:
source (Observable[Union[T, U]])
func (Callable[[Union[T, U]], TypeGuard[U]])
- Return type:
Observable[U]
- stdlibx.streams.methods.base.is_not_none(source)[source]¶
- Parameters:
source (Observable[Union[T, None]])
- Return type:
Observable[T]
- stdlibx.streams.methods.base.map_(source, func)[source]¶
- Parameters:
source (Observable[T])
func (Callable[[T], U])
- Return type:
Observable[U]
- stdlibx.streams.methods.base.start_with(source, value)[source]¶
- Parameters:
source (Observable[T])
value (T)
- Return type:
Observable[T]