🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:23:46 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _flatmap.cpython-38.pyc
Read Only
U v�i� � @ sN d dl mZ d dlmZmZmZmZmZmZ d dl m Z m Z m Z d dl m Z d dlmZ d dlmZmZ ed�Zed�Zde e eeeef eeeef e e d �d d �Zdeeee e f ee e ge e f d �dd�Zdee ee e ge e f d�dd�Zeeee e df f ee e ge e f d �dd�ZdddgZd S )� )�Future)�Any�Callable�Optional�TypeVar�Union�cast)� Observable�from_� from_future)� operators)�identity)�Mapper� MapperIndexed�_T1�_T2N)�source�mapper�mapper_indexed�returnc s2 t ttt d�� �fdd� }| �t�|�t�� �S )N)�x�ir c sT � r � | �n�r�| |�nt }t|t�r8ttd|��}nt|t�rH|}nt|�}|S )Nz Future[Any])r � isinstancer r r r r )r r Z mapper_result�result�r r � �M/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_flatmap.py� projection s � � z&_flat_map_internal.<locals>.projection)r �intr r �pipe�opsZ 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 )N�r r c s. t � �rt| � d�}nt| � fdd�d�}|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 �<lambda>? � z-flat_map_.<locals>.flat_map.<locals>.<lambda>��callabler! �r �retr# r r �flat_map) s zflat_map_.<locals>.flat_map�r 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| � fdd�d�}|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_.<locals>.flat_map_indexed.<locals>.<lambda>r# r) r+ r0 r r �flat_map_indexedI s z+flat_map_indexed_.<locals>.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_.<locals>.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 �<module> s: �� �� ! �� �
💾 Save Changes
❌ Cancel