ObservableBase typing.Observable |
AnonymousObservable ObservableBase |
BlockingObservable typing.Observable |
GroupedObservable ObservableBase |
ConnectableObservable ObservableBase |
---|---|---|---|---|
__await__ | ||||
__add__ | ||||
__iadd__ | ||||
__getitem__ | ||||
__iter__ | ||||
_subscribe_core | _subscribe_core | _subscribe_core | _subscribe_core | |
subscribe_ | subscribe_ | |||
subscribe | subscribe | subscribe | ||
pipe | ||||
connect | ||||
auto_connect | ||||
first | ||||
first_or_default | ||||
for_each | ||||
last | ||||
last_or_default | ||||
to_marbles_blocking | ||||
to_iterable |
- Remove first, firt_or_default, ... from BlockingObservable
- Subclass ObservableBase for BlockingObservable ?
- Create Observable class
- Transfer magic methods from ObservableBase to Observable
ObservableBase typing.Observable |
Observable ObservableBase |
AnonymousObservable ObservableBase |
BlockingObservable ObservableBase |
GroupedObservable ObservableBase |
ConnectableObservable ObservableBase |
---|---|---|---|---|---|
__await__ | |||||
__add__ | |||||
__iadd__ | |||||
__getitem__ | |||||
__iter__ | |||||
_subscribe_core | _subscribe_core | _subscribe_core | _subscribe_core | ||
subscribe_ | subscribe_ | ||||
subscribe | subscribe | subscribe | |||
pipe | |||||
connect | |||||
auto_connect |