Searched defs:stream_encoder (Results 1 – 5 of 5) sorted by relevance
302 let mut stream_encoder = EncoderWriter::new(&mut stream_encoded, config); in every_possible_split_of_input() localVariable353 let mut stream_encoder = EncoderWriter::new(&mut interrupting_writer, config); in retrying_writes_that_error_with_interrupted_works() localVariable418 let mut stream_encoder = EncoderWriter::new(&mut partial_writer, config); in writes_that_only_write_part_of_input_and_sometimes_interrupt_produce_correct_encoded_data() localVariable489 let mut stream_encoder = EncoderWriter::new(&mut stream_encoded, config); in do_encode_random_config_matches_normal_encode() localVariable
166 let mut stream_encoder = EncoderStringWriter::new(config); in every_possible_split_of_input() localVariable
288 let mut stream_encoder = EncoderWriter::new(&mut stream_encoded, &engine); in every_possible_split_of_input() localVariable339 let mut stream_encoder = EncoderWriter::new(&mut interrupting_writer, &engine); in retrying_writes_that_error_with_interrupted_works() localVariable404 let mut stream_encoder = EncoderWriter::new(&mut partial_writer, &engine); in writes_that_only_write_part_of_input_and_sometimes_interrupt_produce_correct_encoded_data() localVariable475 let mut stream_encoder = EncoderWriter::new(&mut stream_encoded, &engine); in do_encode_random_config_matches_normal_encode() localVariable
163 let mut stream_encoder = EncoderStringWriter::new(&engine); in every_possible_split_of_input() localVariable191 let mut stream_encoder = EncoderStringWriter::new(&engine); in incremental_writes() localVariable
210 protobuf::StreamEncoder stream_encoder(null_stream, buffer); in CodeToPullInProtoEncoder() local