def process_data(self, argv=None, input_stream=sys.stdin.buffer, output_stream=sys.__stdout__.buffer):
    while True:
        execute_meta = self.process_protocol_execute(input_stream)
        resp = self.streaming_handle(self.lines)
        send_packet(output_stream, execute_meta, resp)
        self.lines = []
        if self.is_finish:
            break
def process_data(self, argv=None, input_stream=sys.stdin.buffer, output_stream=sys.__stdout__.buffer):
    while True:
        execute_meta = self.process_protocol_execute(input_stream)
        resp = self.streaming_handle(self.lines)
        send_packet(output_stream, execute_meta, resp)
        self.lines = []
        if self.is_finish:
            break