| /external/rust/android-crates-io/crates/tracing-subscriber/tests/ |
| D | option.rs | 25 let subscriber = tracing_subscriber::registry().with(LevelFilter::INFO); in just_layer() localVariable
31 let subscriber = tracing_subscriber::registry() in subscriber_and_option_some_layer() localVariable
40 let subscriber = tracing_subscriber::registry() in subscriber_and_option_none_layer() localVariable
49 let subscriber = tracing_subscriber::registry().with(None::<LevelFilter>); in just_option_some_layer() localVariable
56 let subscriber = tracing_subscriber::registry().with(Some(LevelFilter::ERROR)); in just_option_none_layer() localVariable
64 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
75 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
86 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
99 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
110 let subscriber = tracing_subscriber::registry() in none_outside_doesnt_override_max_level() localVariable
[all …]
|
| D | same_len_filters.rs | 17 let subscriber = subscriber.with(filter); in same_length_targets() localVariable
45 let subscriber = subscriber.with(filter); in same_num_fields_event() localVariable
74 let subscriber = subscriber.with(filter); in same_num_fields_and_name_len() localVariable
|
| D | field_filter.rs | 24 let subscriber = subscriber.with(filter); in field_filter_events() localVariable
62 let subscriber = subscriber.with(filter); in field_filter_spans() localVariable
98 let subscriber = subscriber.with(filter); in record_after_created() localVariable
|
| D | hinted_layer_filters_dont_break_other_layers.rs | 15 let subscriber = tracing_subscriber::registry() in layer_filters() localVariable
39 let subscriber = tracing_subscriber::registry() in layered_layer_filters() localVariable
61 let subscriber = tracing_subscriber::registry() in out_of_order() localVariable
87 let subscriber = tracing_subscriber::registry().with(layered1).with(layered2); in mixed_layered() localVariable
|
| D | vec.rs | 9 let subscriber = tracing_subscriber::registry().with(Vec::<LevelFilter>::new()); in just_empty_vec() localVariable
15 let subscriber = tracing_subscriber::registry() in layer_and_empty_vec() localVariable
|
| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| D | ByteBufferStoringSubscriberTest.java | 63 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in doesNotRequestMoreThanMaxBytes() local
81 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax() local
106 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(1); in blockingTransfer_waitsForFullOutputBuffer() local
147 … ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnComplete() local
176 … ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnError() local
200 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_stopsOnInterrupt() local
231 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(Long.MAX_VALUE); in blockingTransfer_returnsEndOfStreamWithRepeatedCalls() local
246 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfNoDataBuffered() local
257 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfComplete() local
271 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(2); in noDataTransferredIfError() local
[all …]
|
| D | StoringSubscriberTest.java | 52 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in doesNotStoreMoreThanMaxElements() local
73 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsEmptyEventWithOutstandingDemand() local
80 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsCompleteOnComplete() local
89 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsErrorOnError() local
99 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in errorWrapsCheckedExceptions() local
108 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in deliversMessagesInTheCorrectOrder() local
136 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(10); in stochastic_subscriberSeemsThreadSafe() local
|
| D | SimplePublisherTest.java | 54 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateSuccessWorks() local
67 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateFailureWorks() local
130 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in oneDemandWorks() local
154 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in highDemandWorks() local
185 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in writeFuturesDoNotCompleteUntilAfterOnNext() local
203 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in completeFuturesDoNotCompleteUntilAfterOnComplete() local
224 ControllableSubscriber<Integer> subscriber = new ControllableSubscriber<>(); in errorFuturesDoNotCompleteUntilAfterOnError() local
244 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in completeBeforeSubscribeIsDeliveredOnSubscribe() local
254 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in errorBeforeSubscribeIsDeliveredOnSubscribe() local
266 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(Integer.MAX_VALUE); in writeBeforeSubscribeIsDeliveredOnSubscribe() local
[all …]
|
| D | AddingTrailingDataSubscriberTest.java | 50 Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, in trailingDataHasItems_shouldSendAdditionalData() local
67 …Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, () -> ne… in trailingDataEmpty_shouldNotSendAdditionalData() local
82 …Subscriber<Integer> subscriber = new AddingTrailingDataSubscriber<>(downstreamSubscriber, () -> nu… in trailingDataNull_shouldCompleteNormally() local
91 private void publishData(Subscriber<Integer> subscriber) { in publishData()
|
| /external/rust/android-crates-io/crates/tracing-subscriber/src/layer/ |
| D | tests.rs | 93 let subscriber = in downcasts_to_subscriber() localVariable
166 let subscriber = crate::registry() in mixed_with_unfiltered() localVariable
174 let subscriber = crate::registry().with(NopLayer).with( in mixed_with_unfiltered_layered() localVariable
184 let subscriber = crate::registry() in mixed_interleaved() localVariable
194 let subscriber = crate::registry() in mixed_layered() localVariable
202 let subscriber = crate::registry() in plf_only_unhinted() localVariable
212 let subscriber = crate::registry() in plf_only_unhinted_nested_outer() localVariable
233 let subscriber = dbg!(crate::registry().with( in plf_only_unhinted_nested_inner() localVariable
244 let subscriber = dbg!(crate::registry() in unhinted_nested_inner() localVariable
257 let subscriber = dbg!(crate::registry() in unhinted_nested_inner_mixed() localVariable
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/pagination/async/ |
| D | PaginationSubscription.java | 28 protected final Subscriber subscriber; field in PaginationSubscription
108 BuilderT subscriber(Subscriber subscriber); in subscriber() argument
117 private Subscriber subscriber; field in PaginationSubscription.BuilderImpl
121 public BuilderT subscriber(Subscriber subscriber) { in subscriber() argument
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| D | ByteBuffersAsyncRequestBodyTest.java | 76 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompleted() local
88 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompletedWhenARequestIsMadeForMoreBuffersThanAreAvailable() local
103 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsThreadSafeAndMarkedAsCompletedExactlyOnce() local
131 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsNotMarkedAsCompletedWhenThereAreRemainingBuffersToPublish() local
148 TestSubscriber subscriber = new TestSubscriber(); in subscriberReceivesAllBuffers() local
163 TestSubscriber subscriber = new TestSubscriber(); in multipleSubscribersReceiveTheSameResults() local
180 TestSubscriber subscriber = new TestSubscriber(); in canceledSubscriberDoesNotReturnNewResults() local
|
| D | FileAsyncRequestBodyTest.java | 121 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsShorterThanAlreadyRead_failsBecauseTooShort() local
144 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsShorterThanExistingLength_failsBecauseTooShort() local
170 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsLongerThanExistingLength_failsBecauseTooLong() local
196 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsTouched_failsBecauseUpdatedModificationTime() local
220 ControllableSubscriber subscriber = new ControllableSubscriber(); in changingFile_fileGetsDeleted_failsBecauseDeleted() local
|
| /external/aws-sdk-java-v2/core/auth/src/test/java/software/amazon/awssdk/auth/signer/internal/ |
| D | DigestComputingSubscriberTest.java | 40 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_computesCorrectSha256() local
55 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_futureCancelledBeforeSubscribe_cancelsSubscription() local
68 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(); in test_publisherCallsOnError_errorPropagatedToFuture() local
84 DigestComputingSubscriber subscriber = DigestComputingSubscriber.forSha256(sdkChecksum); in test_computesCorrectSdkChecksum() local
|
| /external/rust/android-crates-io/crates/tracing-subscriber/tests/env_filter/ |
| D | main.rs | 22 let subscriber = subscriber.with(filter); in level_filter_event() localVariable
55 let subscriber = subscriber.with(filter); in same_name_spans() localVariable
75 let subscriber = subscriber.with(filter); in level_filter_event_with_target() localVariable
111 let subscriber = Registry::default().with(filter).with(layer); in level_filter_event_with_target_and_span_global() localVariable
143 let subscriber = subscriber.with(filter); in not_order_dependent() localVariable
174 let subscriber = subscriber.with(filter); in add_directive_enables_event() localVariable
204 let subscriber = subscriber.with(filter); in span_name_filter_is_dynamic() localVariable
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| D | HandlerSubscriberBlackboxVerificationTest.java | 48 HandlerSubscriber<Long> subscriber = new HandlerSubscriber<>(channel.eventLoop(), 2, 4); in createSubscriber() local
60 public void triggerRequest(Subscriber<? super Long> subscriber) { in triggerRequest()
75 final HandlerSubscriber<T> subscriber; field in HandlerSubscriberBlackboxVerificationTest.SubscriberWithChannel
77 public SubscriberWithChannel(EmbeddedChannel channel, HandlerSubscriber<T> subscriber) { in SubscriberWithChannel()
|
| /external/aws-sdk-java-v2/core/http-auth-aws/src/test/java/software/amazon/awssdk/http/auth/aws/internal/signer/io/ |
| D | ChecksumSubscriberTest.java | 46 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.singleton(checksum)); in checksum_computesCorrectSha256() local
64 …ChecksumSubscriber subscriber = new ChecksumSubscriber(Arrays.asList(sha256Checksum, crc32Checksum… in checksum_withMultipleChecksums_shouldComputeCorrectChecksums() local
80 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.emptyList()); in checksum_futureCancelledBeforeSubscribe_cancelsSubscription() local
94 ChecksumSubscriber subscriber = new ChecksumSubscriber(Collections.emptyList()); in checksum_publisherCallsOnError_errorPropagatedToFuture() local
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/ |
| D | AsyncRequestBodyTest.java | 77 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(buffer -> { in hasCorrectContent() local
119 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in fromBytesCopiesTheProvidedByteArray() local
138 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in fromBytesUnsafeDoesNotCopyTheProvidedByteArray() local
159 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in safeByteBufferBuildersCopyTheProvidedBuffer() local
187 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in unsafeByteBufferBuildersDoNotCopyTheProvidedBuffer() local
215 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in nonRewindingByteBufferBuildersReadFromTheInputBufferPosition() local
247 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in safeNonRewindingByteBufferBuildersCopyFromTheInputBufferPosition() local
274 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(buffer -> { in rewindingByteBufferBuildersDoNotRewindTheInputBuffer() local
293 Subscriber<ByteBuffer> subscriber = new SimpleSubscriber(publishedBuffer::set); in rewindingByteBufferBuildersReadTheInputBufferFromTheBeginning() local
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/ |
| D | EmptyPublisher.java | 11 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe()
21 private final Subscriber subscriber; field in EmptyPublisher.EmptySubscription
24 EmptySubscription(Subscriber subscriber) { in EmptySubscription()
|
| /external/aws-sdk-java-v2/test/http-client-tests/src/main/java/software/amazon/awssdk/http/ |
| D | EmptyPublisher.java | 26 public void subscribe(Subscriber<? super ByteBuffer> subscriber) { in subscribe()
36 private final Subscriber subscriber; field in EmptyPublisher.EmptySubscription
39 EmptySubscription(Subscriber subscriber) { in EmptySubscription()
|
| /external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/ |
| D | DefaultEventStreamResponseHandlerBuilder.java | 41 private Supplier<Subscriber<EventT>> subscriber; field in DefaultEventStreamResponseHandlerBuilder
79 public SubBuilderT subscriber(Supplier<Subscriber<EventT>> eventSubscriber) { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
85 public SubBuilderT subscriber(Consumer<EventT> eventConsumer) { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
90 Supplier<Subscriber<EventT>> subscriber() { in subscriber() method in DefaultEventStreamResponseHandlerBuilder
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/nrs/util/ |
| D | SubscriberProbe.java | 33 private final Subscriber<T> subscriber; field in SubscriberProbe
35 public SubscriberProbe(Subscriber<T> subscriber, String name) { in SubscriberProbe()
40 SubscriberProbe(Subscriber<T> subscriber, String name, long start) { in SubscriberProbe()
|
| /external/rust/android-crates-io/crates/tracing-subscriber/tests/layer_filters/ |
| D | vec.rs | 91 let subscriber = tracing_subscriber::registry().with(vec![unfiltered, info, debug]); in mixed_max_level_hint() localVariable
111 let subscriber = tracing_subscriber::registry().with(vec![warn, info, debug]); in all_filtered_max_level_hint() localVariable
119 let subscriber = tracing_subscriber::registry().with(Vec::<MockLayer>::new()); in empty_vec() localVariable
|
| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter.cc | 18 void SocketHandleWaiter::Subscribe(Subscriber* subscriber, in Subscribe()
26 void SocketHandleWaiter::Unsubscribe(Subscriber* subscriber, in Unsubscribe()
35 void SocketHandleWaiter::UnsubscribeAll(Subscriber* subscriber) { in UnsubscribeAll()
46 void SocketHandleWaiter::OnHandleDeletion(Subscriber* subscriber, in OnHandleDeletion()
|
| /external/rust/android-crates-io/crates/tracing/tests/ |
| D | enabled.rs | 8 let subscriber = subscriber::mock() in level_and_target() localVariable
29 let subscriber = subscriber::mock() in span_and_event() localVariable
|