Home
last modified time | relevance | path

Searched defs:stream (Results 1 – 25 of 2706) sorted by relevance

12345678910>>...109

/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_stream_peer.cc18 void QuicStreamPeer::SetWriteSideClosed(bool value, QuicStream* stream) { in SetWriteSideClosed()
24 QuicStreamOffset stream_bytes_written, QuicStream* stream) { in SetStreamBytesWritten()
32 void QuicStreamPeer::SetSendWindowOffset(QuicStream* stream, in SetSendWindowOffset()
39 QuicByteCount QuicStreamPeer::bytes_consumed(QuicStream* stream) { in bytes_consumed()
44 void QuicStreamPeer::SetReceiveWindowOffset(QuicStream* stream, in SetReceiveWindowOffset()
51 void QuicStreamPeer::SetMaxReceiveWindow(QuicStream* stream, in SetMaxReceiveWindow()
57 QuicByteCount QuicStreamPeer::SendWindowSize(QuicStream* stream) { in SendWindowSize()
62 QuicStreamOffset QuicStreamPeer::ReceiveWindowOffset(QuicStream* stream) { in ReceiveWindowOffset()
68 QuicByteCount QuicStreamPeer::ReceiveWindowSize(QuicStream* stream) { in ReceiveWindowSize()
73 QuicStreamOffset QuicStreamPeer::SendWindowOffset(QuicStream* stream) { in SendWindowOffset()
[all …]
/external/oj-libjdwp/src/share/back/
DinStream.c41 inStream_init(PacketInputStream *stream, jdwpPacket packet) in inStream_init()
54 inStream_id(PacketInputStream *stream) in inStream_id()
60 inStream_command(PacketInputStream *stream) in inStream_command()
66 readBytes(PacketInputStream *stream, void *dest, int size) in readBytes()
87 inStream_skipBytes(PacketInputStream *stream, jint size) { in inStream_skipBytes()
92 inStream_readBoolean(PacketInputStream *stream) in inStream_readBoolean()
104 inStream_readByte(PacketInputStream *stream) in inStream_readByte()
112 inStream_readBytes(PacketInputStream *stream, int length, jbyte *buf) in inStream_readBytes()
119 inStream_readChar(PacketInputStream *stream) in inStream_readChar()
127 inStream_readShort(PacketInputStream *stream) in inStream_readShort()
[all …]
DoutStream.c39 commonInit(PacketOutputStream *stream) in commonInit()
56 outStream_initCommand(PacketOutputStream *stream, jint id, in outStream_initCommand()
72 outStream_initReply(PacketOutputStream *stream, jint id) in outStream_initReply()
85 outStream_id(PacketOutputStream *stream) in outStream_id()
91 outStream_command(PacketOutputStream *stream) in outStream_command()
99 writeBytes(PacketOutputStream *stream, void *source, int size) in writeBytes()
138 outStream_writeBoolean(PacketOutputStream *stream, jboolean val) in outStream_writeBoolean()
145 outStream_writeByte(PacketOutputStream *stream, jbyte val) in outStream_writeByte()
151 outStream_writeChar(PacketOutputStream *stream, jchar val) in outStream_writeChar()
158 outStream_writeShort(PacketOutputStream *stream, jshort val) in outStream_writeShort()
[all …]
/external/mesa3d/src/gallium/auxiliary/util/
Du_dump_state.c45 util_stream_writef(FILE *stream, const char *format, ...) in util_stream_writef()
57 util_dump_bool(FILE *stream, int value) in util_dump_bool()
63 util_dump_int(FILE *stream, long long int value) in util_dump_int()
69 util_dump_uint(FILE *stream, long long unsigned value) in util_dump_uint()
75 util_dump_float(FILE *stream, double value) in util_dump_float()
89 util_dump_string(FILE *stream, const char *str) in util_dump_string()
97 util_dump_enum(FILE *stream, const char *value) in util_dump_enum()
103 util_dump_array_begin(FILE *stream) in util_dump_array_begin()
109 util_dump_array_end(FILE *stream) in util_dump_array_end()
115 util_dump_elem_begin(UNUSED FILE *stream) in util_dump_elem_begin()
[all …]
/external/antlr/runtime/C/src/
Dantlr3rewritestreams.c65 freeRS (pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream) in freeRS()
108 freeNodeRS(pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream) in freeNodeRS()
174 expungeRS(pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream) in expungeRS()
189 pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream; in antlr3RewriteRuleElementStreamNewAE() local
259 pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream; in antlr3RewriteRuleElementStreamNewAEE() local
282 pANTLR3_REWRITE_RULE_ELEMENT_STREAM stream; in antlr3RewriteRuleElementStreamNewAEV() local
311 pANTLR3_REWRITE_RULE_TOKEN_STREAM stream; in antlr3RewriteRuleTOKENStreamNewAE() local
335 pANTLR3_REWRITE_RULE_TOKEN_STREAM stream; in antlr3RewriteRuleTOKENStreamNewAEE() local
354 pANTLR3_REWRITE_RULE_TOKEN_STREAM stream; in antlr3RewriteRuleTOKENStreamNewAEV() local
375 pANTLR3_REWRITE_RULE_SUBTREE_STREAM stream; in antlr3RewriteRuleSubtreeStreamNewAE() local
[all …]
/external/freetype/src/base/
Dftstream.c34 FT_Stream_OpenMemory( FT_Stream stream, in FT_Stream_OpenMemory()
48 FT_Stream_Close( FT_Stream stream ) in FT_Stream_Close()
56 FT_Stream_Seek( FT_Stream stream, in FT_Stream_Seek()
91 FT_Stream_Skip( FT_Stream stream, in FT_Stream_Skip()
102 FT_Stream_Pos( FT_Stream stream ) in FT_Stream_Pos()
109 FT_Stream_Read( FT_Stream stream, in FT_Stream_Read()
118 FT_Stream_ReadAt( FT_Stream stream, in FT_Stream_ReadAt()
163 FT_Stream_TryRead( FT_Stream stream, in FT_Stream_TryRead()
192 FT_Stream_ExtractFrame( FT_Stream stream, in FT_Stream_ExtractFrame()
214 FT_Stream_ReleaseFrame( FT_Stream stream, in FT_Stream_ReleaseFrame()
[all …]
/external/grpc-grpc/third_party/nanopb/
Dpb_encode.c60 static bool checkreturn buf_write(pb_ostream_t *stream, const pb_byte_t *buf, size_t count) in buf_write()
73 pb_ostream_t stream; in pb_ostream_from_buffer() local
88 bool checkreturn pb_write(pb_ostream_t *stream, const pb_byte_t *buf, size_t count) in pb_write()
113 static bool checkreturn encode_array(pb_ostream_t *stream, const pb_field_t *field, in encode_array()
202 static bool checkreturn encode_basic_field(pb_ostream_t *stream, in encode_basic_field()
274 static bool checkreturn encode_callback_field(pb_ostream_t *stream, in encode_callback_field()
294 static bool checkreturn encode_field(pb_ostream_t *stream, in encode_field()
313 static bool checkreturn default_extension_encoder(pb_ostream_t *stream, in default_extension_encoder()
333 static bool checkreturn encode_extension_field(pb_ostream_t *stream, in encode_extension_field()
372 bool checkreturn pb_encode(pb_ostream_t *stream, const pb_field_t fields[], const void *src_struct) in pb_encode()
[all …]
Dpb_decode.c76 static bool checkreturn buf_read(pb_istream_t *stream, pb_byte_t *buf, size_t count) in buf_read()
90 bool checkreturn pb_read(pb_istream_t *stream, pb_byte_t *buf, size_t count) in pb_read()
126 static bool checkreturn pb_readbyte(pb_istream_t *stream, pb_byte_t *buf) in pb_readbyte()
146 pb_istream_t stream; in pb_istream_from_buffer() local
172 static bool checkreturn pb_decode_varint32(pb_istream_t *stream, uint32_t *dest) in pb_decode_varint32()
208 bool checkreturn pb_decode_varint(pb_istream_t *stream, uint64_t *dest) in pb_decode_varint()
230 bool checkreturn pb_skip_varint(pb_istream_t *stream) in pb_skip_varint()
241 bool checkreturn pb_skip_string(pb_istream_t *stream) in pb_skip_string()
250 bool checkreturn pb_decode_tag(pb_istream_t *stream, pb_wire_type_t *wire_type, uint32_t *tag, bool… in pb_decode_tag()
276 bool checkreturn pb_skip_field(pb_istream_t *stream, pb_wire_type_t wire_type) in pb_skip_field()
[all …]
/external/nanopb-c/
Dpb_encode.c74 static bool checkreturn buf_write(pb_ostream_t *stream, const pb_byte_t *buf, size_t count) in buf_write()
88 pb_ostream_t stream; in pb_ostream_from_buffer() local
103 bool checkreturn pb_write(pb_ostream_t *stream, const pb_byte_t *buf, size_t count) in pb_write()
147 static bool checkreturn encode_array(pb_ostream_t *stream, const pb_field_t *field, in encode_array()
341 static bool checkreturn encode_basic_field(pb_ostream_t *stream, in encode_basic_field()
430 static bool checkreturn encode_callback_field(pb_ostream_t *stream, in encode_callback_field()
450 static bool checkreturn encode_field(pb_ostream_t *stream, in encode_field()
469 static bool checkreturn default_extension_encoder(pb_ostream_t *stream, in default_extension_encoder()
489 static bool checkreturn encode_extension_field(pb_ostream_t *stream, in encode_extension_field()
528 bool checkreturn pb_encode(pb_ostream_t *stream, const pb_field_t fields[], const void *src_struct) in pb_encode()
[all …]
Dpb_decode.c87 static bool checkreturn buf_read(pb_istream_t *stream, pb_byte_t *buf, size_t count) in buf_read()
102 bool checkreturn pb_read(pb_istream_t *stream, pb_byte_t *buf, size_t count) in pb_read()
141 static bool checkreturn pb_readbyte(pb_istream_t *stream, pb_byte_t *buf) in pb_readbyte()
161 pb_istream_t stream; in pb_istream_from_buffer() local
187 static bool checkreturn pb_decode_varint32_eof(pb_istream_t *stream, uint32_t *dest, bool *eof) in pb_decode_varint32_eof()
249 bool checkreturn pb_decode_varint32(pb_istream_t *stream, uint32_t *dest) in pb_decode_varint32()
255 bool checkreturn pb_decode_varint(pb_istream_t *stream, uint64_t *dest) in pb_decode_varint()
278 bool checkreturn pb_skip_varint(pb_istream_t *stream) in pb_skip_varint()
289 bool checkreturn pb_skip_string(pb_istream_t *stream) in pb_skip_string()
298 bool checkreturn pb_decode_tag(pb_istream_t *stream, pb_wire_type_t *wire_type, uint32_t *tag, bool… in pb_decode_tag()
[all …]
/external/libdrm/etnaviv/
Detnaviv_cmd_stream.c53 etna_cmd_stream_priv(struct etna_cmd_stream *stream) in etna_cmd_stream_priv()
60 void (*reset_notify)(struct etna_cmd_stream *stream, void *priv), in etna_cmd_stream_new()
63 struct etna_cmd_stream_priv *stream = NULL; in etna_cmd_stream_new() local
99 drm_public void etna_cmd_stream_del(struct etna_cmd_stream *stream) in etna_cmd_stream_del()
109 static void reset_buffer(struct etna_cmd_stream *stream) in reset_buffer()
123 drm_public uint32_t etna_cmd_stream_timestamp(struct etna_cmd_stream *stream) in etna_cmd_stream_timestamp()
128 static uint32_t append_bo(struct etna_cmd_stream *stream, struct etna_bo *bo) in append_bo()
145 static uint32_t bo2idx(struct etna_cmd_stream *stream, struct etna_bo *bo, in bo2idx()
177 static void flush(struct etna_cmd_stream *stream, int in_fence_fd, in flush()
224 drm_public void etna_cmd_stream_flush(struct etna_cmd_stream *stream) in etna_cmd_stream_flush()
[all …]
/external/pigweed/pw_stream/
Dnull_stream_test.cc21 namespace pw::stream { namespace
25 NullStream stream; in TEST() local
30 NullStream stream; in TEST() local
35 NullStream stream; in TEST() local
41 NullStream stream; in TEST() local
46 CountingNullStream stream; in TEST() local
51 CountingNullStream stream; in TEST() local
56 CountingNullStream stream; in TEST() local
62 CountingNullStream stream; in TEST() local
69 CountingNullStream stream; in TEST() local
/external/mesa3d/src/gallium/drivers/i915/
Di915_debug.c71 struct debug_stream *stream, in PRINTF()
83 static boolean debug( struct debug_stream *stream, const char *name, unsigned len ) in debug()
128 static boolean debug_prim( struct debug_stream *stream, const char *name, in debug_prim()
158 static boolean debug_program( struct debug_stream *stream, const char *name, unsigned len ) in debug_program()
179 static boolean debug_chain( struct debug_stream *stream, const char *name, unsigned len ) in debug_chain()
203 static boolean debug_variable_length_prim( struct debug_stream *stream ) in debug_variable_length_prim()
227 struct debug_stream *stream, in BITS()
261 struct debug_stream *stream, in FLAG()
280 static boolean debug_load_immediate( struct debug_stream *stream, in debug_load_immediate()
387 static boolean debug_load_indirect( struct debug_stream *stream, in debug_load_indirect()
[all …]
/external/sonic/
Dsonic.c89 sonicStream stream) in sonicGetSpeed()
96 sonicStream stream, in sonicSetSpeed()
104 sonicStream stream) in sonicGetPitch()
111 sonicStream stream, in sonicSetPitch()
119 sonicStream stream) in sonicGetRate()
126 sonicStream stream, in sonicSetRate()
137 sonicStream stream) in sonicGetChordPitch()
144 sonicStream stream, in sonicSetChordPitch()
152 sonicStream stream) in sonicGetQuality()
159 sonicStream stream, in sonicSetQuality()
[all …]
/external/nanopb-c/tests/alltypes_proto3_callback/
Dencode_alltypes_callback.c13 static bool write_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_varint()
19 static bool write_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_svarint()
25 static bool write_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed32()
31 static bool write_fixed64(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed64()
37 static bool write_string(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_string()
43 static bool write_submsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_submsg()
50 static bool write_emptymsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_emptymsg()
57 static bool write_repeated_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_varint()
71 static bool write_repeated_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_svarint()
85 static bool write_repeated_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_fixed32()
[all …]
/external/nanopb-c/tests/alltypes_callback/
Dencode_alltypes_callback.c13 static bool write_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_varint()
19 static bool write_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_svarint()
25 static bool write_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed32()
31 static bool write_fixed64(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed64()
37 static bool write_string(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_string()
43 static bool write_submsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_submsg()
50 static bool write_emptymsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_emptymsg()
57 static bool write_repeated_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_varint()
71 static bool write_repeated_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_svarint()
85 static bool write_repeated_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_fixed32()
[all …]
/external/grpc-grpc/third_party/nanopb/tests/alltypes_callback/
Dencode_alltypes_callback.c13 static bool write_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_varint()
19 static bool write_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_svarint()
25 static bool write_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed32()
31 static bool write_fixed64(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_fixed64()
37 static bool write_string(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_string()
43 static bool write_submsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_submsg()
50 static bool write_emptymsg(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_emptymsg()
57 static bool write_repeated_varint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_varint()
71 static bool write_repeated_svarint(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_svarint()
85 static bool write_repeated_fixed32(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) in write_repeated_fixed32()
[all …]
/external/libcxx/test/std/input.output/file.streams/fstreams/ofstream.cons/
Dpath.pass.cpp36 std::ofstream stream(p); in main() local
40 std::ifstream stream(p); in main() local
46 std::ifstream stream(p, std::ios_base::out); in main() local
53 std::wofstream stream(p); in main() local
57 std::wifstream stream(p); in main() local
63 std::wifstream stream(p, std::ios_base::out); in main() local
/external/rust/crates/futures/tests/
Dstream_futures_ordered.rs15 let mut stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesOrdered<_>>(); in works_1() localVariable
36 let mut stream = vec![a_rx.boxed(), join(b_rx, c_rx).map(|(a, b)| Ok(a? + b?)).boxed()] in works_2() localVariable
56 let mut stream = FuturesOrdered::new(); in test_push_front() localVariable
88 let mut stream = FuturesOrdered::new(); in test_push_back() localVariable
114 let stream = vec![future::ready::<i32>(1), future::ready::<i32>(2), future::ready::<i32>(3)] in from_iterator() localVariable
127 let mut stream = vec![ in queue_never_unblocked() localVariable
156 let mut stream = FuturesOrdered::new(); in test_push_front_negative() localVariable
Dstream_futures_unordered.rs65 let mut stream = vec![a_rx.boxed(), join(b_rx, c_rx).map(|(a, b)| Ok(a? + b?)).boxed()] in works_2() localVariable
81 let stream = vec![future::ready::<i32>(1), future::ready::<i32>(2), future::ready::<i32>(3)] in from_iterator() localVariable
94 let mut stream = vec![ in finished_future() localVariable
119 let mut stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesUnordered<_>>(); in iter_mut_cancel() localVariable
139 let mut stream = in iter_mut_len() localVariable
180 let stream = vec![ in iter_cancel() localVariable
202 let stream = vec![future::pending::<()>(), future::pending::<()>(), future::pending::<()>()] in iter_len() localVariable
223 let stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesUnordered<_>>(); in into_iter_cancel() localVariable
225 let stream = stream in into_iter_cancel() localVariable
247 let stream = vec![future::pending::<()>(), future::pending::<()>(), future::pending::<()>()] in into_iter_len() localVariable
[all …]
/external/cronet/buildtools/third_party/libc++/trunk/test/std/input.output/file.streams/fstreams/ofstream.cons/
Dpath.pass.cpp39 std::ofstream stream(p); in main() local
43 std::ifstream stream(p); in main() local
49 std::ifstream stream(p, std::ios_base::out); in main() local
58 std::wofstream stream(p); in main() local
62 std::wifstream stream(p); in main() local
68 std::wifstream stream(p, std::ios_base::out); in main() local
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java103 AbstractClientStream stream = in cancel_doNotAcceptOk() local
122 AbstractClientStream stream = in cancel_failsOnNull() local
133 AbstractClientStream stream = new BaseAbstractClientStream(allocator, state, new BaseSink() { in cancel_notifiesOnlyOnce() local
150 AbstractClientStream stream = in startFailsOnNullListener() local
160 AbstractClientStream stream = in cantCallStartTwice() local
171 AbstractClientStream stream = in inboundDataReceived_failsOnNullFrame() local
183 AbstractClientStream stream = in inboundHeadersReceived_notifiesListener() local
194 AbstractClientStream stream = in inboundHeadersReceived_failsIfStatusReported() local
207 AbstractClientStream stream = in inboundHeadersReceived_acceptsGzipContentEncoding() local
222 AbstractClientStream stream = in inboundHeadersReceived_contentEncodingIsCaseInsensitive() local
[all …]
/external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/file/common/internal/
DLazyByteArrayInputStreamTest.java39 InputStream stream = new LazyByteArrayInputStream(spy); in callableIsCalledLazilyExactlyOnce() local
69 InputStream stream = new LazyByteArrayInputStream(spy); in available_onStreamThatHasNotBeenRead_returnsZero() local
77 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in available_returnsRemainingCallableBytes() local
86 InputStream stream = new LazyByteArrayInputStream(spy); in close_callsCallable() local
94 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in read_returnsCallableBytes() local
100 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in skip_skipsCallableBytes() local
107 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in markSupported_returnsTrue() local
114 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in reset_fromFirstByte() local
124 InputStream stream = new LazyByteArrayInputStream(CONTENT_CALLABLE); in markAndReset_fromMidwayByte() local
/external/mesa3d/src/etnaviv/drm/
Detnaviv_cmd_stream.c53 void etna_cmd_stream_realloc(struct etna_cmd_stream *stream, size_t n) in etna_cmd_stream_realloc()
83 etna_cmd_stream_priv(struct etna_cmd_stream *stream) in etna_cmd_stream_priv()
90 void (*force_flush)(struct etna_cmd_stream *stream, void *priv), in etna_cmd_stream_new()
93 struct etna_cmd_stream_priv *stream = NULL; in etna_cmd_stream_new() local
129 void etna_cmd_stream_del(struct etna_cmd_stream *stream) in etna_cmd_stream_del()
139 void etna_cmd_stream_force_flush(struct etna_cmd_stream *stream) in etna_cmd_stream_force_flush()
147 uint32_t etna_cmd_stream_timestamp(struct etna_cmd_stream *stream) in etna_cmd_stream_timestamp()
152 static uint32_t append_bo(struct etna_cmd_stream *stream, struct etna_bo *bo) in append_bo()
170 static uint32_t bo2idx(struct etna_cmd_stream *stream, struct etna_bo *bo, in bo2idx()
208 void etna_cmd_stream_flush(struct etna_cmd_stream *stream, int in_fence_fd, in etna_cmd_stream_flush()
[all …]
/external/rust/crates/futures-test/src/
Dassert.rs29 let mut stream = &mut $stream; localVariable
31 let stream = $crate::__private::Pin::new(stream); localVariable
63 let mut stream = &mut $stream; localVariable
65 let stream = $crate::__private::Pin::new(stream); localVariable
107 let mut stream = &mut $stream; localVariable
109 let stream = $crate::__private::Pin::new(stream); localVariable

12345678910>>...109