🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:29:33 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable
🔄 Refresh
✏️
Editing: throw.py
Read Only
from typing import Any, Optional, Union from reactivex import Observable, abc from reactivex.scheduler import ImmediateScheduler def throw_( exception: Union[str, Exception], scheduler: Optional[abc.SchedulerBase] = None ) -> Observable[Any]: exception_ = exception if isinstance(exception, Exception) else Exception(exception) def subscribe( observer: abc.ObserverBase[Any], scheduler: Optional[abc.SchedulerBase] = None ) -> abc.DisposableBase: _scheduler = scheduler or ImmediateScheduler.singleton() def action(scheduler: abc.SchedulerBase, state: Any) -> None: observer.on_error(exception_) return _scheduler.schedule(action) return Observable(subscribe) __all__ = ["throw_"]
💾 Save Changes
❌ Cancel