code: def handle_stream(msg):
      
      if not msg.gateway.is_sensor(msg.node_id):
          return None
      stream = msg.gateway.const.Stream(msg.sub_type)
      handler = stream.get_handler(msg.gateway.handlers)
      if handler is None:
          return None
      return handler(msg)
docs: Process a stream type message.