def on_stream_event()

in src/pubsub/ipc_pubsub.py [0:0]

• 7 lines of code
• 2 McCabe index (conditional complexity)

        def on_stream_event(self, event: SubscriptionResponseMessage) -> None:
            try:

                log.debug('IPC MESSAGE RECEIVED: {}'.format(event))

                message = str(event.binary_message.message, "utf-8")
                
                
                self.executor.submit(self.message_callback, self.ipc_subscribe_topic, message) # pragma: no cover

            except Exception as err:
                log.error('EXCEPTION: Exception Raised from IPC Topic Subscriber. ERROR MESSAGE: {} - STREAM EVENT: {}'.format(err, event))