rpc: publish-subscribe: notify: make state optional

Signed-off-by: Florian Scherf <f.scherf@pengutronix.de>

Author: fscherf

aiohttp_json_rpc/rpc.py

@@ -419,12 +419,15 @@ def filter(self, topics):
             if len(topics & client.subscriptions) > 0:
                 yield client
 
-    async def notify(self, topic, data=None):
+    async def notify(self, topic, data=None, state=False):
         if type(topic) is not str:
             raise ValueError
 
-        self.state[topic] = data
+        if state:
+            self.state[topic] = data
+
         notification = None
+
         for client in self.filter(topic):
             try:
                 if notification is None:

tests/test_publish_subscribe.py

@@ -74,7 +74,7 @@ async def test_state(rpc_context):
 
     # setup rpc
     rpc_context.rpc.add_topics('topic')
-    await rpc_context.rpc.notify('topic', 'foo')
+    await rpc_context.rpc.notify('topic', 'foo', state=True)
 
     # setup client
     message = asyncio.Future()