🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:39:26 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators
🔄 Refresh
✏️
Editing: _asobservable.py
Read Only
from typing import Callable, Optional, TypeVar from reactivex import Observable, abc _T = TypeVar("_T") def as_observable_() -> Callable[[Observable[_T]], Observable[_T]]: def as_observable(source: Observable[_T]) -> Observable[_T]: """Hides the identity of an observable sequence. Args: source: Observable source to hide identity from. Returns: An observable sequence that hides the identity of the source sequence. """ def subscribe( observer: abc.ObserverBase[_T], scheduler: Optional[abc.SchedulerBase] = None, ) -> abc.DisposableBase: return source.subscribe(observer, scheduler=scheduler) return Observable(subscribe) return as_observable __all__ = ["as_observable_"]
💾 Save Changes
❌ Cancel