🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:55:23 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observer
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observer
🔄 Refresh
✏️
Editing: observeonobserver.py
Read Only
from typing import TypeVar from .scheduledobserver import ScheduledObserver _T = TypeVar("_T") class ObserveOnObserver(ScheduledObserver[_T]): def _on_next_core(self, value: _T) -> None: super()._on_next_core(value) self.ensure_active() def _on_error_core(self, error: Exception) -> None: super()._on_error_core(error) self.ensure_active() def _on_completed_core(self) -> None: super()._on_completed_core() self.ensure_active()
💾 Save Changes
❌ Cancel