Searched defs:TestSubscriber (Results 1 – 8 of 8) sorted by relevance
21 struct TestSubscriber; in event_macros_dont_infinite_loop() struct22 impl Subscriber for TestSubscriber { in event_macros_dont_infinite_loop() implementation
212 private class TestSubscriber implements Subscriber<ListObjectsV2Response> { class in ListObjectsV2PaginatorsIntegrationTest220 public TestSubscriber(long requestCount) { in TestSubscriber() method in ListObjectsV2PaginatorsIntegrationTest.TestSubscriber
129 private class TestSubscriber implements Subscriber<ByteBuffer> { class in ChecksumValidatingPublisherTest135 TestSubscriber(byte[] expected) { in TestSubscriber() method in ChecksumValidatingPublisherTest.TestSubscriber
172 private class TestSubscriber implements Subscriber<ByteBuffer> { class in S3ChecksumValidatingPublisherTest177 TestSubscriber() { in TestSubscriber() method in S3ChecksumValidatingPublisherTest.TestSubscriber
954 struct TestSubscriber; in events_dont_infinite_loop() struct955 impl Subscriber for TestSubscriber { in events_dont_infinite_loop() implementation1003 struct TestSubscriber; in spans_dont_infinite_loop() struct1004 impl Subscriber for TestSubscriber { in spans_dont_infinite_loop() implementation1043 struct TestSubscriber; in default_dispatch() struct1044 impl Subscriber for TestSubscriber { in default_dispatch() implementation
288 static final class TestSubscriber implements Subscriber<ByteBuffer> { class in PublisherAdapterTest
40 private static class TestSubscriber implements Subscriber<ByteBuffer> { class in ByteBuffersAsyncRequestBodyTest
567 struct TestSubscriber { struct568 inner: Arc<SubscriberInner>,571 impl TestSubscriber { implementation594 impl Subscriber for TestSubscriber { implementation