fixed lint and Value

semiversus · Jun 1, 2021 · 993b340 · 993b340
1 parent c545085
commit 993b340
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/broqer/operator.py b/broqer/operator.py
@@ -37,7 +37,6 @@ def originator(self, publisher: Publisher):
         if self._subscriptions:
             self._originator.subscribe(self)
 
-
     def __ror__(self, publisher: Publisher) -> Publisher:
         if self._originator is not None:
             raise TypeError('operator already applied')

diff --git a/broqer/value.py b/broqer/value.py
@@ -3,7 +3,7 @@
 from typing import Any
 
 # pylint: disable=cyclic-import
-from broqer import Publisher, Subscriber, NONE
+from broqer import Publisher, NONE
 from broqer.operator import Operator
 
 
@@ -20,9 +20,8 @@ class Value(Operator):
     1
     """
     def __init__(self, init=NONE):
-        Publisher.__init__(self, init)
-        Subscriber.__init__(self)
-        self._originator = None  # type: typing.Optional[Publisher]
+        Operator.__init__(self)
+        self._state = init
 
     def emit(self, value: Any,
              who: Publisher = None) -> None:  # pylint: disable=unused-argument