Searched refs:output_stream (Results 1 – 3 of 3) sorted by relevance
283 output_stream = self.outgoing_connections.get(connection_value)284 if output_stream is None:285 output_stream = self._interleave_get_incoming_stream(connection_value)287 if output_stream:289 output_stream.send(request.data)293 …logging.error('Output stream: %s not found for the connection_value: %s', output_stream, connectio…
309 output_stream = self.streams.get(stream_id)310 if output_stream:312 output_stream.send(request.data)317 … logging.error('Output stream: %s not found for the stream_id: %s', output_stream, stream_id)
71 let mut output_stream = CodedOutputStream::vec(&mut proto_bytes); in generate_proto_bytes() localVariable72 let write_result = request.write_to_with_cached_sizes(&mut output_stream); in generate_proto_bytes()