| /aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | framed_read.rs | 24 macro_rules! assert_read { macro
78 assert_read!(pin!(framed).poll_next(cx), 0); in read_multi_frame_in_packet()
79 assert_read!(pin!(framed).poll_next(cx), 1); in read_multi_frame_in_packet()
80 assert_read!(pin!(framed).poll_next(cx), 2); in read_multi_frame_in_packet()
96 assert_read!(pin!(framed).poll_next(cx), 0); in read_multi_frame_across_packets()
97 assert_read!(pin!(framed).poll_next(cx), 1); in read_multi_frame_across_packets()
98 assert_read!(pin!(framed).poll_next(cx), 2); in read_multi_frame_across_packets()
112 assert_read!(pin!(framed).poll_next(cx), 0x04); in read_multi_frame_in_packet_after_codec_changed()
115 assert_read!(pin!(framed).poll_next(cx), 0x08); in read_multi_frame_in_packet_after_codec_changed()
133 assert_read!(pin!(framed).poll_next(cx), 0); in read_not_ready()
[all …]
|
| D | framed_stream.rs | 12 macro_rules! assert_read { macro
33 assert_read!(pin!(io).poll_next(cx), b"abcdef".to_vec()); in return_none_after_error()
36 assert_read!(pin!(io).poll_next(cx), b"more data".to_vec()); in return_none_after_error()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/csv-core/src/ |
| D | reader.rs | 1729 macro_rules! assert_read { macro
1748 assert_read!(rdr, &[], &mut [], 0, 0, End); in stream_empty()
1757 assert_read!(rdr, b(" "), &mut [0], 1, 1, InputEmpty); in stream_space()
1758 assert_read!(rdr, &[], &mut [0], 0, 0, Field { record_end: true }); in stream_space()
1759 assert_read!(rdr, &[], &mut [0], 0, 0, End); in stream_space()
1768 assert_read!(rdr, b(","), &mut [0], 1, 0, Field { record_end: false }); in stream_comma()
1769 assert_read!(rdr, &[], &mut [0], 0, 0, Field { record_end: true }); in stream_comma()
1770 assert_read!(rdr, &[], &mut [0], 0, 0, End); in stream_comma()
1783 assert_read!(rdr, inp, out, 2, 2, OutputFull); in stream_output_chunks()
1787 assert_read!(rdr, inp, out, 2, 2, OutputFull); in stream_output_chunks()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/tests/ |
| D | stream_into_async_read.rs | 7 macro_rules! assert_read { macro
53 assert_read!(reader, &mut buf, 3); in test_into_async_read()
56 assert_read!(reader, &mut buf, 2); in test_into_async_read()
59 assert_read!(reader, &mut buf, 3); in test_into_async_read()
62 assert_read!(reader, &mut buf, 2); in test_into_async_read()
65 assert_read!(reader, &mut buf, 3); in test_into_async_read()
68 assert_read!(reader, &mut buf, 2); in test_into_async_read()
71 assert_read!(reader, &mut buf, 0); in test_into_async_read()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-util/src/io/ |
| D | mod.rs | 177 assert_read(Chain::new(self, next)) in chain()
353 (assert_read(r), assert_write(w)) in split()
379 assert_read(Take::new(self, limit)) in take()
828 pub(crate) fn assert_read<R>(reader: R) -> R in assert_read() function
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-util/src/stream/try_stream/ |
| D | mod.rs | 1191 crate::io::assert_read(IntoAsyncRead::new(self)) in into_async_read()
|
| /aosp_15_r20/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| H A D | SocketChannelTest.java | 2656 assert_read$LByteBuffer(true); in test_read$LByteBufferII_blocking()
2663 assert_read$LByteBuffer(false); in test_read$LByteBufferII_nonblocking()
2666 private void assert_read$LByteBuffer(boolean isBlocking) throws IOException { in assert_read$LByteBuffer()
|
| /aosp_15_r20/prebuilts/module_sdk/art/current/test-exports/java/ |
| D | core-tests.jar | META-INF/
META-INF/MANIFEST.MF
META-INF/maven/
META- ... |
| /aosp_15_r20/prebuilts/module_sdk/art/1/test-exports/java/ |
| D | core-tests.jar | META-INF/
META-INF/MANIFEST.MF
META-INF/maven/
META- ... |