🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 13:46:58 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
subject
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/subject
🔄 Refresh
✏️
Editing: innersubscription.py
Read Only
import threading from typing import TYPE_CHECKING, Optional, TypeVar from .. import abc if TYPE_CHECKING: from .subject import Subject _T = TypeVar("_T") class InnerSubscription(abc.DisposableBase): def __init__( self, subject: "Subject[_T]", observer: Optional[abc.ObserverBase[_T]] = None ): self.subject = subject self.observer = observer self.lock = threading.RLock() def dispose(self) -> None: with self.lock: if not self.subject.is_disposed and self.observer: if self.observer in self.subject.observers: self.subject.observers.remove(self.observer) self.observer = None
💾 Save Changes
❌ Cancel