code: def handle(self, message, _server=None, _request=None):
          
          if not message:
              return
  
          if message[-1] == 0:
              message = message[:-1]
  
          string = message.decode('utf-8')
          handle = self._handle(json.loads(string), message, _server, _request)
          for out in handle:
              if out == None:
                  return
              try:
                  yield json.dumps(out, cls=VarlinkEncoder).encode('utf-8')
              except ConnectionError as e:
                  try:
                      handle.throw(e)
                  except StopIteration:
                      pass
docs: This generator function handles any incoming message.
  
          Write any returned bytes to the output stream.
  
              >>> for outgoing_message in service.handle(incoming_message):
              >>>    connection.write(outgoing_message)