U
vi6 @ s d dl mZmZ d dlmZmZmZmZmZ ddl m
Z
ddl m Z m
Z
mZmZ ddlmZ eddd ZG d
d d ee eZee e ee ge
f Zd d gZd
S ) )ABCabstractmethod)CallableGenericOptionalTypeVarUnion )DisposableBase) ObserverBase OnCompletedOnErrorOnNext)
SchedulerBase_T_outT) covariantc @ sV e Zd ZdZdZedddeeee e
e f ee ee ee
edddZdS ) ObservableBasezHObservable abstract base class.
Represents a push-style collection. N) scheduler)on_nexton_error on_completedr returnc C s t dS )a Subscribe an observer to the observable sequence.
Args:
observer: [Optional] The object that is to receive
notifications.
scheduler: [Optional] The default scheduler to use for this
subscription.
Returns:
Disposable object representing an observer's subscription
to the observable sequence.
N)NotImplementedError)selfr r r r r r I/opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/observable.py subscribe s zObservableBase.subscribe)NNN)__name__
__module__ __qualname____doc__ __slots__r r r r r r r
r r r
r r r r r r s r SubscriptionN)abcr r typingr r r r r Z
disposabler
Zobserverr r r
r r r r r r" __all__r r r r s