fixed typo

CHANGELOG.md

@@ -1,3 +1,7 @@
+## next version
+
+* fixed typo ("orginator" fixed to "origintator")
+
 ## 2.4.0
 
 * changed default behavior of error_handler: now it raises an exception

broqer/op/bitwise.py

@@ -26,7 +26,7 @@ def __init__(self, publisher_bit_mapping: Dict, init: int = 0) -> None:
         MultiOperator.__init__(self, *publisher_bit_mapping)
 
         self._init = init
-        self._missing = set(self._orginators)
+        self._missing = set(self._originators)
         self._publisher_bit_mapping = publisher_bit_mapping
 
     def subscribe(self, subscriber: 'Subscriber',
@@ -45,7 +45,7 @@ def subscribe(self, subscriber: 'Subscriber',
     def unsubscribe(self, subscriber: Subscriber) -> None:
         MultiOperator.unsubscribe(self, subscriber)
         if not self._subscriptions:
-            self._missing.update(self._orginators)
+            self._missing.update(self._originators)
             self._state = NONE
 
     def get(self):
@@ -68,7 +68,7 @@ def get(self):
         return state
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if all(who is not p for p in self._orginators):
+        if all(who is not p for p in self._originators):
             raise ValueError('Emit from non assigned publisher')
 
         # remove source publisher from ._missing

broqer/op/cache.py

@@ -43,10 +43,10 @@ def __init__(self, publisher: Publisher, init: Any = NONE) -> None:
         self._state = init
 
     def get(self) -> TValue:
-        return self._orginator.get()
+        return self._originator.get()
 
     def emit(self, value: TValue, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if value != self._state:

broqer/op/combine_latest.py

@@ -73,14 +73,14 @@ def __init__(self, *publishers: Publisher, map_: Callable[..., Any] = None,
     def unsubscribe(self, subscriber: Subscriber) -> None:
         MultiOperator.unsubscribe(self, subscriber)
         if not self._subscriptions:
-            self._missing = set(self._orginators)
+            self._missing = set(self._originators)
             self._partial_state[:] = [NONE for _ in self._partial_state]
 
     def get(self):
         if self._subscriptions:
             return self._state
 
-        values = tuple(p.get() for p in self._orginators)
+        values = tuple(p.get() for p in self._originators)
 
         if NONE in values:
             return NONE
@@ -91,7 +91,7 @@ def get(self):
         return self._map(*values)
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if all(who is not p for p in self._orginators):
+        if all(who is not p for p in self._originators):
             raise ValueError('Emit from non assigned publisher')
 
         # remove source publisher from ._missing

broqer/op/concat.py

@@ -13,10 +13,10 @@ def __init__(self, *operators):
 
     def apply(self, publisher: Publisher) -> Publisher:
         # concat each operator in the following step
-        orginator = publisher
+        originator = publisher
 
         for operator in self._operators:
-            orginator = operator.apply(orginator)
+            originator = operator.apply(originator)
 
         # the source publisher is the last operator in the chain
-        return orginator
+        return originator

broqer/op/filter_.py

@@ -44,7 +44,7 @@ def get(self) -> Any:
         if self._subscriptions:
             return self._state
 
-        value = self._orginator.get()  # type: Any
+        value = self._originator.get()  # type: Any
 
         if self._unpack:
             # assert isinstance(value, (list, tuple))
@@ -57,7 +57,7 @@ def get(self) -> Any:
         return NONE
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if self._unpack:
@@ -97,17 +97,17 @@ def get(self) -> Any:
         if self._subscriptions:
             return self._state
 
-        assert isinstance(self._orginator, Publisher)
+        assert isinstance(self._originator, Publisher)
 
-        value = self._orginator.get()  # type: Any
+        value = self._originator.get()  # type: Any
 
         if bool(value):
             return value
 
         return NONE
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if bool(value):
@@ -127,17 +127,17 @@ def get(self) -> Any:
         if self._subscriptions:
             return self._state
 
-        assert isinstance(self._orginator, Publisher)
+        assert isinstance(self._originator, Publisher)
 
-        value = self._orginator.get()  # type: Any
+        value = self._originator.get()  # type: Any
 
         if not bool(value):
             return value
 
         return NONE
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if not bool(value):

broqer/op/map_.py

@@ -62,7 +62,7 @@ def get(self) -> TValue:
         if self._subscriptions:
             return self._state
 
-        value = self._orginator.get()  # type: TValue
+        value = self._originator.get()  # type: TValue
 
         if value is NONE:
             return value
@@ -74,7 +74,7 @@ def get(self) -> TValue:
         return self._function(value)
 
     def emit(self, value: TValue, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if self._unpack:

broqer/op/map_async.py

@@ -172,7 +172,7 @@ def __init__(self, publisher: Publisher,
             self._queue = deque(maxlen=maxlen)
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         # check if a coroutine is already running

broqer/op/throttle.py

@@ -50,7 +50,7 @@ def get(self):
         return Publisher.get(self)
 
     def emit(self, value: Any, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         if not self._timer.is_running():

broqer/operator.py

@@ -27,23 +27,23 @@ class Operator(Publisher, Subscriber, metaclass=OperatorMeta):
     def __init__(self, publisher: Publisher) -> None:
         Publisher.__init__(self)
         Subscriber.__init__(self)
-        self._orginator = publisher
+        self._originator = publisher
         self.add_dependencies(publisher)
 
     def subscribe(self, subscriber: 'Subscriber',
                   prepend: bool = False) -> SubscriptionDisposable:
         disposable = Publisher.subscribe(self, subscriber, prepend)
 
         if len(self._subscriptions) == 1:  # if this was the first subscription
-            self._orginator.subscribe(self)
+            self._originator.subscribe(self)
 
         return disposable
 
     def unsubscribe(self, subscriber: Subscriber) -> None:
         Publisher.unsubscribe(self, subscriber)
 
         if not self._subscriptions:
-            self._orginator.unsubscribe(self)
+            self._originator.unsubscribe(self)
             Publisher.reset_state(self)
 
     def notify(self, value: TValue) -> None:
@@ -79,15 +79,15 @@ class MultiOperator(Publisher, Subscriber):
     def __init__(self, *publishers: Publisher) -> None:
         Publisher.__init__(self)
         Subscriber.__init__(self)
-        self._orginators = publishers
+        self._originators = publishers
         self.add_dependencies(*publishers)
 
     def subscribe(self, subscriber: 'Subscriber',
                   prepend: bool = False) -> SubscriptionDisposable:
         disposable = Publisher.subscribe(self, subscriber, prepend)
 
         if len(self._subscriptions) == 1:  # if this was the first subscription
-            for publisher in self._orginators:
+            for publisher in self._originators:
                 # subscribe to all dependent publishers
                 publisher.subscribe(self)
 
@@ -96,7 +96,7 @@ def subscribe(self, subscriber: 'Subscriber',
     def unsubscribe(self, subscriber: Subscriber) -> None:
         Publisher.unsubscribe(self, subscriber)
         if not self._subscriptions:
-            for publisher in self._orginators:
+            for publisher in self._originators:
                 publisher.unsubscribe(self)
             Publisher.reset_state(self)
 

broqer/operator_overloading.py

@@ -20,10 +20,10 @@ def __init__(self, publisher: Publisher, value, operation) -> None:
             self.inherit_type(publisher.inherited_type)
 
     def get(self):
-        return self._operation(self._orginator.get(), self._value)
+        return self._operation(self._originator.get(), self._value)
 
     def emit(self, value: Any_, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         result = self._operation(value, self._value)
@@ -42,10 +42,10 @@ def __init__(self, publisher: Publisher, value, operation) -> None:
             self.inherit_type(publisher.inherited_type)
 
     def get(self):
-        return self._operation(self._value, self._orginator.get())
+        return self._operation(self._value, self._originator.get())
 
     def emit(self, value: Any_, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         result = self._operation(self._value, value)
@@ -63,10 +63,10 @@ def __init__(self, publisher: Publisher, operation) -> None:
             self.inherit_type(publisher.inherited_type)
 
     def get(self):
-        return self._operation(self._orginator.get())
+        return self._operation(self._originator.get())
 
     def emit(self, value: Any_, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         result = self._operation(value)
@@ -84,7 +84,7 @@ def __init__(self, publisher: Publisher, attribute_name) -> None:
         self.inherit_type(publisher.inherited_type)
 
     def get(self):
-        value = self._orginator.get()  # may raise ValueError
+        value = self._originator.get()  # may raise ValueError
         attribute = getattr(value, self._attribute_name)
         if self._args is None:
             return attribute
@@ -96,7 +96,7 @@ def __call__(self, *args, **kwargs):
         return self
 
     def emit(self, value: Any_, who: Publisher) -> None:
-        if who is not self._orginator:
+        if who is not self._originator:
             raise ValueError('Emit from non assigned publisher')
 
         attribute = getattr(value, self._attribute_name)