@@ -20,9 +20,9 @@ def __init__(self, value):
20
20
creates a subject that caches its last value and starts with the
21
21
specified value.
22
22
23
- Keyword parameters :
24
- :param T value: Initial value sent to observers when no other
25
- value has been received by the subject yet.
23
+ Args :
24
+ value: Initial value sent to observers when no other value has been
25
+ received by the subject yet.
26
26
"""
27
27
28
28
super (BehaviorSubject , self ).__init__ ()
@@ -73,7 +73,7 @@ def on_completed(self) -> None:
73
73
o .on_completed ()
74
74
75
75
def on_error (self , error : Exception ) -> None :
76
- """Notifie all subscribed observers with the exception."""
76
+ """Notifies all subscribed observers with the exception."""
77
77
os = None
78
78
with self .lock :
79
79
self .check_disposed ()
@@ -88,7 +88,7 @@ def on_error(self, error: Exception) -> None:
88
88
o .on_error (error )
89
89
90
90
def on_next (self , value : Any ) -> None :
91
- """Notifie all subscribed observers with the value."""
91
+ """Notifies all subscribed observers with the value."""
92
92
os = None
93
93
with self .lock :
94
94
self .check_disposed ()
@@ -103,7 +103,7 @@ def dispose(self) -> None:
103
103
"""Release all resources.
104
104
105
105
Releases all resources used by the current instance of the
106
- ReplaySubject class and unsubscribe all observers.
106
+ BehaviorSubject class and unsubscribe all observers.
107
107
"""
108
108
with self .lock :
109
109
self .is_disposed = True
0 commit comments