U
vi @ sN d dl mZ d dlmZmZmZmZmZmZ d dl m
Z
m Z m Z d dl m
Z d dlmZ d dlmZmZ edZedZde
e eeeef eeeef e
e d
d d Zdeeee
e f ee
e ge
e f d
ddZdee ee
e ge
e f dddZeeee
e df f ee
e ge
e f d
ddZdddgZd S ) )Future)AnyCallableOptionalTypeVarUnioncast)
Observablefrom_ from_future) operators)identity)Mapper
MapperIndexed_T1_T2N)sourcemappermapper_indexedreturnc s2 t ttt d fdd }| t|t S )N)xir c sT r | nr| |nt }t|tr8ttd|}nt|trH|}nt|}|S )Nz Future[Any])r
isinstancer r r r r
)r r Z
mapper_resultresultr r M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_flatmap.py
projection s
z&_flat_map_internal..projection)r intr r pipeopsZ map_indexedZ merge_all)r r r r r r r _flat_map_internal
s
r! )r r c s t t t t d fdd }|S )Nr r c s. t rt| d}nt| fddd}|S )aO One of the Following:
Projects each element of an observable sequence to an observable
sequence and merges the resulting observable sequences into one
observable sequence.
Example:
>>> flat_map(source)
Args:
source: Source observable to flat map.
Returns:
An operator function that takes a source observable and returns
an observable sequence whose elements are the result of invoking
the one-to-many transform function on each element of the
input sequence .
r c s S Nr _r# r r ? z-flat_map_..flat_map..callabler! r retr# r r flat_map) s zflat_map_..flat_mapr r r )r r- r r# r flat_map_& s r/ )r r c s t t t t d fdd }|S )Nr" c s. t rt| d}nt| fddd}|S )a
One of the Following:
Projects each element of an observable sequence to an observable
sequence and merges the resulting observable sequences into one
observable sequence.
Example:
>>> flat_map_indexed(source)
Args:
source: Source observable to flat map.
Returns:
An observable sequence whose elements are the result of invoking
the one-to-many transform function on each element of the input
sequence.
r c s S r$ r r% r0 r r r' ^ r( z=flat_map_indexed_..flat_map_indexed..r# r) r+ r0 r r flat_map_indexedI s z+flat_map_indexed_..flat_map_indexed)r r )r r1 r r0 r flat_map_indexed_F s r2 z Future[_T2]c s t t t t d fdd }|S )Nr" c s | t t S )a Projects each element of an observable sequence into a new
sequence of observable sequences by incorporating the element's
index and then transforms an observable sequence of observable
sequences into an observable sequence producing values only
from the most recent observable sequence.
Args:
source: Source observable to flat map latest.
Returns:
An observable sequence whose elements are the result of
invoking the transform function on each element of source
producing an observable of Observable sequences and that at
any point in time produces the elements of the most recent
inner observable sequence that has been received.
)r r mapZ
switch_latest)r r# r r flat_map_latestg s z)flat_map_latest_..flat_map_latestr. )r r4 r r# r flat_map_latest_d s r5 )NN)N)N)asyncior typingr r r r r r Z reactivexr r
r r r Zreactivex.internal.basicr
Zreactivex.typingr r r r r! r/ r2 r5 __all__r r r r s: !