🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:29:16 | 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: _multicast.cpython-38.pyc
Read Only
U v�i{ � @ s� d dl mZmZmZmZ d dlmZmZmZ d dlm Z d dl m Z ed�Z ed�Zd ddd�eeje eeeej geje f eeee gee f eee geee ee f f d �d d �ZdS ) � )�Callable�Optional�TypeVar�Union)�ConnectableObservable� Observable�abc)� operators)�CompositeDisposable�_TSource�_TResultN)�subject_factory�mapper)�subjectr r �returnc s0 t t tt t tt f d�� ��fdd� }|S )a� Multicasts the source sequence notifications through an instantiated subject into all uses of the sequence within a mapper function. Each subscription to the resulting sequence causes a separate multicast invocation, exposing the sequence resulting from the mapper function's invocation. For specializations with fixed subject types, see Publish, PublishLast, and Replay. Examples: >>> res = multicast(observable) >>> res = multicast( subject_factory=lambda scheduler: Subject(), mapper=lambda x: x ) Args: subject_factory: Factory function to create an intermediate subject through which the source sequence's elements will be multicast to the mapper function. subject: Subject to push source elements into. mapper: [Optional] Mapper function which can use the multicasted source sequence subject to the policies enforced by the created subject. Specified only if subject_factory" is a factory function. Returns: An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a mapper function. )�sourcer c sP �r6dt jt tt j t jd��� �fdd� }t|�S �sBtd��t� ��}|S )N)�observer� schedulerr c sH �st ���tj�|�d��}� s&t �� |�j| |d�}t||�|��S )N)r )r )�AssertionError�pipe�ops� multicast� subscriber �connect)r r Z connectableZ subscription)r r r � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_multicast.pyr 8 s � �z0multicast_.<locals>.multicast.<locals>.subscribez!multicast: Subject cannot be None)N) r Z ObserverBaser r � SchedulerBaseZDisposableBaser � ValueErrorr )r r �ret�r r r )r r r 3 s �� z multicast_.<locals>.multicast)r r r r r )r r r r r r r � multicast_ s )�r )N)�typingr r r r Z reactivexr r r r r Zreactivex.disposabler r r Z SubjectBaser r r r r r �<module> s& �� � ��
💾 Save Changes
❌ Cancel