diff --git a/trustgraph-flow/trustgraph/rev_gateway/dispatcher.py b/trustgraph-flow/trustgraph/rev_gateway/dispatcher.py index bb8e29bc..5377a09e 100644 --- a/trustgraph-flow/trustgraph/rev_gateway/dispatcher.py +++ b/trustgraph-flow/trustgraph/rev_gateway/dispatcher.py @@ -18,6 +18,12 @@ class WebSocketResponder: """Capture the response data""" self.response = data self.completed = True + + async def __call__(self, data, final=False): + """Make the responder callable for compatibility with requestor""" + await self.send(data) + if final: + self.completed = True class MessageDispatcher: