v1.0.1 Release (#10)

Author: Maxusmusti

docs/index.html

@@ -572,6 +572,7 @@ <h1 class="title">Module <code>state_signals</code></h1>
             raise redis.ConnectionError
         self.subscriber = self.redis.pubsub(ignore_subscribe_messages=True)
         self.subscriber.subscribe(&#34;event-signal-pubsub&#34;)
+        self.channel = self.subscriber.listen()
         self.responder_id = responder_name + &#34;-&#34; + str(uuid.uuid4()) + &#34;-resp&#34;
         self._locked_id = None
         self._locked_tag = None
@@ -622,7 +623,7 @@ <h1 class="title">Module <code>state_signals</code></h1>
         Yield all legal published signals. If a specific tag/published_id
         was locked, only signals with those matching values will be yielded.
         &#34;&#34;&#34;
-        for item in self.subscriber.listen():
+        for item in self.channel:
             data = self._parse_signal(item)
             if data and self._check_target(data):
                 signal = Signal(**data)
@@ -1585,6 +1586,7 @@ <h3>Methods</h3>
             raise redis.ConnectionError
         self.subscriber = self.redis.pubsub(ignore_subscribe_messages=True)
         self.subscriber.subscribe(&#34;event-signal-pubsub&#34;)
+        self.channel = self.subscriber.listen()
         self.responder_id = responder_name + &#34;-&#34; + str(uuid.uuid4()) + &#34;-resp&#34;
         self._locked_id = None
         self._locked_tag = None
@@ -1635,7 +1637,7 @@ <h3>Methods</h3>
         Yield all legal published signals. If a specific tag/published_id
         was locked, only signals with those matching values will be yielded.
         &#34;&#34;&#34;
-        for item in self.subscriber.listen():
+        for item in self.channel:
             data = self._parse_signal(item)
             if data and self._check_target(data):
                 signal = Signal(**data)
@@ -1712,7 +1714,7 @@ <h3>Methods</h3>
     Yield all legal published signals. If a specific tag/published_id
     was locked, only signals with those matching values will be yielded.
     &#34;&#34;&#34;
-    for item in self.subscriber.listen():
+    for item in self.channel:
         data = self._parse_signal(item)
         if data and self._check_target(data):
             signal = Signal(**data)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "state-signals"
-version = "1.0.0"
+version = "1.0.1"
 description = "Package for easy management of state/event signal publishing, subscribing, and responding"
 
 license = "GPL-3.0-only"

python-36/setup.py

@@ -3,7 +3,7 @@
 
 setup(
     name="python36-state_signals",
-    version="1.0.0",
+    version="1.0.1",
     description="Package for easy management of state/event signal publishing, subscribing, and responding",
     url="https://github.com/distributed-system-analysis/state-signals/",
     author="Mustafa Eyceoz",

python-latest/setup.py

@@ -3,7 +3,7 @@
 
 setup(
     name="python3-state_signals",
-    version="1.0.0",
+    version="1.0.1",
     description="Package for easy management of state/event signal publishing, subscribing, and responding",
     url="https://github.com/distributed-system-analysis/state-signals/",
     author="Mustafa Eyceoz",