| /external/mesa3d/src/gallium/auxiliary/util/ |
| D | u_dump_state.c | 45 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/oj-libjdwp/src/share/back/ |
| D | inStream.c | 41 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 …]
|
| D | outStream.c | 39 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/antlr/runtime/C/src/ |
| D | antlr3rewritestreams.c | 65 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/ |
| D | ftstream.c | 34 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/ |
| D | pb_encode.c | 60 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 …]
|
| D | pb_decode.c | 76 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/oboe/src/aaudio/ |
| D | AudioStreamAAudio.cpp | 45 AAudioStream *stream, in oboe_aaudio_data_callback_proc()
112 AAudioStream *stream, in internalErrorCallback()
262 AAudioStream *stream = nullptr; in open() local
322 AAudioStream *stream = mAAudioStream.exchange(nullptr); in close() local
341 DataCallbackResult AudioStreamAAudio::callOnAudioReady(AAudioStream *stream, in callOnAudioReady()
370 AAudioStream *stream = mAAudioStream.load(); in requestStart() local
391 AAudioStream *stream = mAAudioStream.load(); in requestPause() local
408 AAudioStream *stream = mAAudioStream.load(); in requestFlush() local
425 AAudioStream *stream = mAAudioStream.load(); in requestStop() local
434 Result AudioStreamAAudio::requestStop_l(AAudioStream *stream) { in requestStop_l()
[all …]
|
| /external/nanopb-c/ |
| D | pb_encode.c | 74 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 …]
|
| D | pb_decode.c | 87 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/ |
| D | etnaviv_cmd_stream.c | 53 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/mesa3d/src/gallium/drivers/i915/ |
| D | i915_debug.c | 71 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/ |
| D | sonic.c | 89 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/grpc-grpc/third_party/nanopb/tests/alltypes_callback/ |
| D | encode_alltypes_callback.c | 13 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/ |
| D | encode_alltypes_callback.c | 13 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_proto3_callback/ |
| D | encode_alltypes_callback.c | 13 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/ |
| D | path.pass.cpp | 36 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/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractClientStreamTest.java | 103 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/mesa3d/src/etnaviv/drm/ |
| D | etnaviv_cmd_stream.c | 53 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/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_api_dummy.cc | 41 int bidirectional_stream_destroy(bidirectional_stream* stream) { in bidirectional_stream_destroy()
46 int bidirectional_stream_start(bidirectional_stream* stream, const char* url, in bidirectional_stream_start()
54 int bidirectional_stream_read(bidirectional_stream* stream, char* buffer, in bidirectional_stream_read()
60 int bidirectional_stream_write(bidirectional_stream* stream, const char* buffer, in bidirectional_stream_write()
66 void bidirectional_stream_cancel(bidirectional_stream* stream) { in bidirectional_stream_cancel()
70 void bidirectional_stream_disable_auto_flush(bidirectional_stream* stream, in bidirectional_stream_disable_auto_flush()
76 bidirectional_stream* stream, bool delay_headers_until_flush) { in bidirectional_stream_delay_request_headers_until_flush()
80 void bidirectional_stream_flush(bidirectional_stream* stream) { GPR_ASSERT(0); } in bidirectional_stream_flush()
|
| /external/grpc-grpc/third_party/nanopb/tests/fuzztest/ |
| D | fuzzstub.c | 21 pb_istream_t stream; in do_static_decode() local
44 pb_istream_t stream; in do_pointer_decode() local
79 pb_istream_t stream = pb_istream_from_buffer(buffer, msglen); in do_static_roundtrip() local
85 pb_ostream_t stream = pb_ostream_from_buffer(buf2, BUFSIZE); in do_static_roundtrip() local
92 pb_istream_t stream = pb_istream_from_buffer(buf2, msglen2); in do_static_roundtrip() local
98 pb_ostream_t stream = pb_ostream_from_buffer(buf3, BUFSIZE); in do_static_roundtrip() local
126 pb_istream_t stream = pb_istream_from_buffer(buffer, msglen); in do_pointer_roundtrip() local
132 pb_ostream_t stream = pb_ostream_from_buffer(buf2, BUFSIZE); in do_pointer_roundtrip() local
139 pb_istream_t stream = pb_istream_from_buffer(buf2, msglen2); in do_pointer_roundtrip() local
145 pb_ostream_t stream = pb_ostream_from_buffer(buf3, BUFSIZE); in do_pointer_roundtrip() local
|
| /external/nanopb-c/tests/fuzztest/ |
| D | fuzzstub.c | 21 pb_istream_t stream; in do_static_decode() local
44 pb_istream_t stream; in do_pointer_decode() local
79 pb_istream_t stream = pb_istream_from_buffer(buffer, msglen); in do_static_roundtrip() local
85 pb_ostream_t stream = pb_ostream_from_buffer(buf2, BUFSIZE); in do_static_roundtrip() local
92 pb_istream_t stream = pb_istream_from_buffer(buf2, msglen2); in do_static_roundtrip() local
98 pb_ostream_t stream = pb_ostream_from_buffer(buf3, BUFSIZE); in do_static_roundtrip() local
126 pb_istream_t stream = pb_istream_from_buffer(buffer, msglen); in do_pointer_roundtrip() local
132 pb_ostream_t stream = pb_ostream_from_buffer(buf2, BUFSIZE); in do_pointer_roundtrip() local
139 pb_istream_t stream = pb_istream_from_buffer(buf2, msglen2); in do_pointer_roundtrip() local
145 pb_ostream_t stream = pb_ostream_from_buffer(buf3, BUFSIZE); in do_pointer_roundtrip() local
|
| /external/mesa3d/src/gallium/drivers/etnaviv/ |
| D | etnaviv_emit.h | 43 etna_emit_load_state(struct etna_cmd_stream *stream, const uint16_t offset, in etna_emit_load_state()
58 etna_set_state(struct etna_cmd_stream *stream, uint32_t address, uint32_t value) in etna_set_state()
66 etna_set_state_reloc(struct etna_cmd_stream *stream, uint32_t address, in etna_set_state_reloc()
75 etna_set_state_multi(struct etna_cmd_stream *stream, uint32_t base, in etna_set_state_multi()
96 etna_draw_primitives(struct etna_cmd_stream *stream, uint32_t primitive_type, in etna_draw_primitives()
108 etna_draw_indexed_primitives(struct etna_cmd_stream *stream, in etna_draw_indexed_primitives()
124 etna_draw_instanced(struct etna_cmd_stream *stream, in etna_draw_instanced()
144 etna_coalesce_start(struct etna_cmd_stream *stream, in etna_coalesce_start()
153 etna_coalesce_end(struct etna_cmd_stream *stream, in etna_coalesce_end()
173 check_coalsence(struct etna_cmd_stream *stream, struct etna_coalesce *coalesce, in check_coalsence()
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | stream_futures_unordered.rs | 66 let mut stream = vec![a_rx.boxed(), join(b_rx, c_rx).map(|(a, b)| Ok(a? + b?)).boxed()] in works_2() localVariable
82 let stream = vec![future::ready::<i32>(1), future::ready::<i32>(2), future::ready::<i32>(3)] in from_iterator() localVariable
96 let mut stream = vec![ in finished_future() localVariable
121 let mut stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesUnordered<_>>(); in iter_mut_cancel() localVariable
141 let mut stream = in iter_mut_len() localVariable
182 let stream = vec![ in iter_cancel() localVariable
204 let stream = vec![future::pending::<()>(), future::pending::<()>(), future::pending::<()>()] in iter_len() localVariable
225 let stream = vec![a_rx, b_rx, c_rx].into_iter().collect::<FuturesUnordered<_>>(); in into_iter_cancel() localVariable
227 let stream = stream in into_iter_cancel() localVariable
249 let stream = vec![future::pending::<()>(), future::pending::<()>(), future::pending::<()>()] in into_iter_len() localVariable
[all …]
|
| /external/rust/crates/tokio-stream/tests/ |
| D | stream_timeout.rs | 29 let stream = stream::iter(1..=4).then(maybe_sleep).timeout(ms(100)); in basic_usage() localVariable
30 let mut stream = task::spawn(stream); in basic_usage() localVariable
71 let stream = stream::iter(1..=3).then(maybe_sleep).timeout(ms(50)); in return_elapsed_errors_only_once() localVariable
72 let mut stream = task::spawn(stream); in return_elapsed_errors_only_once() localVariable
99 let stream = stream::iter(vec![1, 3, 5]) in no_timeouts() localVariable
103 let mut stream = task::spawn(stream); in no_timeouts() localVariable
|