Home
last modified time | relevance | path

Searched full:subscriber (Results 1 – 25 of 2119) sorted by relevance

12345678910>>...85

/aosp_15_r20/external/rust/android-crates-io/crates/tracing-core/src/
Ddispatcher.rs1 //! Dispatches trace events to [`Subscriber`]s.
5 //! to the subscriber that collects it.
11 //! current subscriber.
13 //! ## Setting the Default Subscriber
15 //! By default, the current subscriber is an empty implementation that does
16 //! nothing. To use a subscriber implementation, it must be set as the default.
18 //! [`set_global_default`]. `with_default` sets the default subscriber for the
19 //! duration of a scope, while `set_global_default` sets a default subscriber
22 //! To use either of these functions, we must first wrap our subscriber in a
23 //! [`Dispatch`], a cloneable, type-erased reference to a subscriber. For
[all …]
Dsubscriber.rs13 /// trace data should implement the `Subscriber` interface. This trait is
16 /// subscriber implementations more modular or improve the ergonomics of writing
19 /// A subscriber is responsible for the following:
21 /// IDs. Implicitly, this means the subscriber may determine the strategy for
30 /// When a span is entered or exited, the subscriber is provided only with the
32 /// that it is up to the subscriber to determine whether and how span _data_ —
35 /// point, the subscriber _may_ choose to store the associated data if it will
37 /// not be needed by the implementations of `enter` and `exit`, the subscriber
42 /// Some trait methods on `Subscriber` have default implementations, either in
43 /// order to reduce the surface area of implementing `Subscriber`, or for
[all …]
/aosp_15_r20/out/soong/.intermediates/external/rust/android-crates-io/crates/tracing-subscriber/libtracing_subscriber/android_arm64_armv8-2a_cortex-a55_rlib_rlib-std/
Dlibtracing_subscriber.rlib.d.raw1 …subscriber/libtracing_subscriber/android_arm64_armv8-2a_cortex-a55_rlib_rlib-std/libtracing_subscr…
3 …subscriber/libtracing_subscriber/android_arm64_armv8-2a_cortex-a55_rlib_rlib-std/libtracing_subscr…
5 external/rust/android-crates-io/crates/tracing-subscriber/src/lib.rs:
6 external/rust/android-crates-io/crates/tracing-subscriber/src/macros.rs:
7 external/rust/android-crates-io/crates/tracing-subscriber/src/field/mod.rs:
8 external/rust/android-crates-io/crates/tracing-subscriber/src/field/debug.rs:
9 external/rust/android-crates-io/crates/tracing-subscriber/src/field/delimited.rs:
10 external/rust/android-crates-io/crates/tracing-subscriber/src/field/display.rs:
11 external/rust/android-crates-io/crates/tracing-subscriber/src/filter/mod.rs:
12 external/rust/android-crates-io/crates/tracing-subscriber/src/filter/filter_fn.rs:
[all …]
Dlibtracing_subscriber.rlib.d1 …subscriber/libtracing_subscriber/android_arm64_armv8-2a_cortex-a55_rlib_rlib-std/libtracing_subscr…
/aosp_15_r20/out/soong/.intermediates/external/rust/android-crates-io/crates/tracing-subscriber/libtracing_subscriber/linux_glibc_x86_64_rlib_rlib-std/
Dlibtracing_subscriber.rlib.d.raw1 …subscriber/libtracing_subscriber/linux_glibc_x86_64_rlib_rlib-std/libtracing_subscriber.rlib: exte…
3 …subscriber/libtracing_subscriber/linux_glibc_x86_64_rlib_rlib-std/libtracing_subscriber.rlib.d.raw…
5 external/rust/android-crates-io/crates/tracing-subscriber/src/lib.rs:
6 external/rust/android-crates-io/crates/tracing-subscriber/src/macros.rs:
7 external/rust/android-crates-io/crates/tracing-subscriber/src/field/mod.rs:
8 external/rust/android-crates-io/crates/tracing-subscriber/src/field/debug.rs:
9 external/rust/android-crates-io/crates/tracing-subscriber/src/field/delimited.rs:
10 external/rust/android-crates-io/crates/tracing-subscriber/src/field/display.rs:
11 external/rust/android-crates-io/crates/tracing-subscriber/src/filter/mod.rs:
12 external/rust/android-crates-io/crates/tracing-subscriber/src/filter/filter_fn.rs:
[all …]
Dlibtracing_subscriber.rlib.d1 …subscriber/libtracing_subscriber/linux_glibc_x86_64_rlib_rlib-std/libtracing_subscriber.rlib: exte…
/aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/tests/
Doption.rs2 use tracing_core::{subscriber::Interest, LevelFilter, Metadata, Subscriber};
8 impl<S: Subscriber> tracing_subscriber::Layer<S> for BasicLayer {
25 let subscriber = tracing_subscriber::registry().with(LevelFilter::INFO); in just_layer() localVariable
26 assert_eq!(subscriber.max_level_hint(), Some(LevelFilter::INFO)); in just_layer()
31 let subscriber = tracing_subscriber::registry() in subscriber_and_option_some_layer() localVariable
34 assert_eq!(subscriber.max_level_hint(), Some(LevelFilter::DEBUG)); in subscriber_and_option_some_layer()
40 let subscriber = tracing_subscriber::registry() in subscriber_and_option_none_layer() localVariable
43 assert_eq!(subscriber.max_level_hint(), Some(LevelFilter::ERROR)); in subscriber_and_option_none_layer()
49 let subscriber = tracing_subscriber::registry().with(None::<LevelFilter>); in just_option_some_layer() localVariable
50 assert_eq!(subscriber.max_level_hint(), Some(LevelFilter::OFF)); in just_option_some_layer()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/
H A DByteBufferStoringSubscriberTest.java63 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in doesNotRequestMoreThanMaxBytes() local
66 subscriber.onSubscribe(subscription); in doesNotRequestMoreThanMaxBytes()
69 subscriber.onNext(fullByteBufferOfSize(2)); in doesNotRequestMoreThanMaxBytes()
72 subscriber.onNext(fullByteBufferOfSize(0)); in doesNotRequestMoreThanMaxBytes()
75 subscriber.onNext(fullByteBufferOfSize(1)); in doesNotRequestMoreThanMaxBytes()
81 ByteBufferStoringSubscriber subscriber = new ByteBufferStoringSubscriber(3); in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax() local
84 subscriber.onSubscribe(subscription); in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax()
87 subscriber.onNext(fullByteBufferOfSize(1)); // After: Storing 1 in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax()
90 subscriber.onNext(fullByteBufferOfSize(50)); // After: Storing 51 in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax()
91 subscriber.transferTo(emptyByteBufferOfSize(48)); // After: Storing 3 in canStoreMoreThanMaxBytesButWontAskForMoreUntilBelowMax()
[all …]
H A DSimplePublisherTest.java36 import org.reactivestreams.Subscriber;
54 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateSuccessWorks() local
55 publisher.subscribe(subscriber); in immediateSuccessWorks()
58 assertThat(subscriber.poll().get().type()).isEqualTo(EventType.ON_COMPLETE); in immediateSuccessWorks()
59 assertThat(subscriber.poll()).isNotPresent(); in immediateSuccessWorks()
67 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(1); in immediateFailureWorks() local
68 publisher.subscribe(subscriber); in immediateFailureWorks()
71 assertThat(subscriber.peek().get().type()).isEqualTo(EventType.ON_ERROR); in immediateFailureWorks()
72 assertThat(subscriber.peek().get().runtimeError()).isEqualTo(error); in immediateFailureWorks()
74 subscriber.poll(); in immediateFailureWorks()
[all …]
H A DStoringSubscriberTest.java52 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in doesNotStoreMoreThanMaxElements() local
55 subscriber.onSubscribe(subscription); in doesNotStoreMoreThanMaxElements()
58 subscriber.onNext(0); in doesNotStoreMoreThanMaxElements()
59 subscriber.onNext(0); in doesNotStoreMoreThanMaxElements()
60 subscriber.peek(); in doesNotStoreMoreThanMaxElements()
63 subscriber.poll(); in doesNotStoreMoreThanMaxElements()
64 subscriber.poll(); in doesNotStoreMoreThanMaxElements()
67 assertThat(subscriber.peek()).isNotPresent(); in doesNotStoreMoreThanMaxElements()
73 StoringSubscriber<Integer> subscriber = new StoringSubscriber<>(2); in returnsEmptyEventWithOutstandingDemand() local
74 subscriber.onSubscribe(mock(Subscription.class)); in returnsEmptyEventWithOutstandingDemand()
[all …]
H A DInputStreamSubscriberTest.java42 import org.reactivestreams.Subscriber;
48 private InputStreamSubscriber subscriber; field in InputStreamSubscriberTest
53 subscriber = new InputStreamSubscriber(); in setup()
58 publisher.subscribe(subscriber); in onComplete_returnsEndOfStream_onRead()
60 assertThat(subscriber.read()).isEqualTo(-1); in onComplete_returnsEndOfStream_onRead()
61 assertThat(subscriber.read(new byte[1])).isEqualTo(-1); in onComplete_returnsEndOfStream_onRead()
62 assertThat(subscriber.read(new byte[1], 0, 1)).isEqualTo(-1); in onComplete_returnsEndOfStream_onRead()
69 publisher.subscribe(subscriber); in onError_throws_onRead()
71 assertThatThrownBy(() -> subscriber.read()).isEqualTo(exception); in onError_throws_onRead()
72 assertThatThrownBy(() -> subscriber.read(new byte[1])).isEqualTo(exception); in onError_throws_onRead()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tracing/tests/
Dspan.rs10 subscriber::with_default,
18 // Create a mock subscriber that will return `true` on calls to in handles_to_the_same_span_are_equal()
19 // `Subscriber::enabled`, so that the spans will be constructed. We in handles_to_the_same_span_are_equal()
20 // won't enter any spans in this test, so the subscriber won't actually in handles_to_the_same_span_are_equal()
22 with_default(subscriber::mock().run(), || { in handles_to_the_same_span_are_equal()
38 with_default(subscriber::mock().run(), || { in handles_to_different_spans_are_not_equal()
57 with_default(subscriber::mock().run(), || { in handles_to_different_spans_with_the_same_metadata_are_not_equal()
69 let subscriber1 = subscriber::mock() in spans_always_go_to_the_subscriber_that_tagged_them()
77 let subscriber2 = subscriber::mock().run(); in spans_always_go_to_the_subscriber_that_tagged_them()
84 // Even though we enter subscriber 2's context, the subscriber that in spans_always_go_to_the_subscriber_that_tagged_them()
[all …]
Devent.rs13 subscriber::with_default,
23 let (subscriber, handle) = subscriber::mock()
38 with_default(subscriber, || {
59 let (subscriber, handle) = subscriber::mock() in event_with_message()
71 with_default(subscriber, || { in event_with_message()
81 let (subscriber, handle) = subscriber::mock() in message_without_delims()
99 with_default(subscriber, || { in message_without_delims()
110 let (subscriber, handle) = subscriber::mock() in string_message_without_delims()
125 with_default(subscriber, || { in string_message_without_delims()
136 let (subscriber, handle) = subscriber::mock() in one_with_everything()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/fmt/
Dmod.rs1 //! A `Subscriber` for formatting and logging `tracing` data.
7 //! implementation of the [`Subscriber`] trait that records `tracing`'s `Event`s
16 //! tracing-subscriber = "0.3"
23 //! Add the following to your executable to initialize the default subscriber:
32 //! The default subscriber installed by `init` enables you to filter events
48 //! You can configure a subscriber instead of using the defaults with
51 //! ### Subscriber
57 //! let subscriber = tracing_subscriber::fmt()
67 //! The output format used by the layer and subscriber in this module is
119 //! // Create a `fmt` subscriber that uses our custom event format, and set it
[all …]
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/
DFlow.java42 * produce items consumed by one or more {@link Subscriber
58 * Subscriber}. It publishes items to the subscriber asynchronously,
61 * TRUE} item to a single subscriber. Because the subscriber receives
69 * public synchronized void subscribe(Subscriber<? super Boolean> subscriber) {
71 * subscriber.onError(new IllegalStateException()); // only one allowed
74 * subscriber.onSubscribe(new OneShotSubscription(subscriber, executor));
78 * private final Subscriber<? super Boolean> subscriber;
82 * OneShotSubscription(Subscriber<? super Boolean> subscriber,
84 * this.subscriber = subscriber;
92 * executor.execute(() -> subscriber.onError(ex));
[all …]
DSubmissionPublisher.java49 import static java.util.concurrent.Flow.Subscriber;
55 * current subscriber receives newly submitted items in the same order
71 * at different rates. Each subscriber uses an independent buffer.
86 * access by each subscriber. But reported estimates of lag and demand
97 * <p>If any Subscriber method throws an exception, its subscription
100 * {@link Flow.Subscriber#onNext onNext}, but exceptions in methods
101 * {@link Flow.Subscriber#onSubscribe onSubscribe},
102 * {@link Flow.Subscriber#onError(Throwable) onError} and
103 * {@link Flow.Subscriber#onComplete() onComplete} are not recorded or
113 * common case in which the only action of a subscriber is to request
[all …]
/aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/
H A DFlow.java42 * produce items consumed by one or more {@link Subscriber
58 * Subscriber}. It publishes items to the subscriber asynchronously,
61 * TRUE} item to a single subscriber. Because the subscriber receives
69 * public synchronized void subscribe(Subscriber<? super Boolean> subscriber) {
71 * subscriber.onError(new IllegalStateException()); // only one allowed
74 * subscriber.onSubscribe(new OneShotSubscription(subscriber, executor));
78 * private final Subscriber<? super Boolean> subscriber;
82 * OneShotSubscription(Subscriber<? super Boolean> subscriber,
84 * this.subscriber = subscriber;
92 * executor.execute(() -> subscriber.onError(ex));
[all …]
H A DSubmissionPublisher.java49 import static java.util.concurrent.Flow.Subscriber;
55 * current subscriber receives newly submitted items in the same order
71 * at different rates. Each subscriber uses an independent buffer.
86 * access by each subscriber. But reported estimates of lag and demand
97 * <p>If any Subscriber method throws an exception, its subscription
100 * {@link Flow.Subscriber#onNext onNext}, but exceptions in methods
101 * {@link Flow.Subscriber#onSubscribe onSubscribe},
102 * {@link Flow.Subscriber#onError(Throwable) onError} and
103 * {@link Flow.Subscriber#onComplete() onComplete} are not recorded or
113 * common case in which the only action of a subscriber is to request
[all …]
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/19/libcore/ojluni/src/main/java/java/util/concurrent/
DFlow.java42 * produce items consumed by one or more {@link Subscriber
58 * Subscriber}. It publishes items to the subscriber asynchronously,
61 * TRUE} item to a single subscriber. Because the subscriber receives
69 * public synchronized void subscribe(Subscriber<? super Boolean> subscriber) {
71 * subscriber.onError(new IllegalStateException()); // only one allowed
74 * subscriber.onSubscribe(new OneShotSubscription(subscriber, executor));
78 * private final Subscriber<? super Boolean> subscriber;
82 * OneShotSubscription(Subscriber<? super Boolean> subscriber,
84 * this.subscriber = subscriber;
92 * executor.execute(() -> subscriber.onError(ex));
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tracing-subscriber/src/layer/
Dcontext.rs1 use tracing_core::{metadata::Metadata, span, subscriber::Subscriber, Event};
8 /// wrapped [`Subscriber`].
11 /// trait should ensure that the `Subscriber` type parameter is *also* bound by the
15 /// use tracing::Subscriber;
22 /// S: Subscriber + for<'a> LookupSpan<'a>,
29 /// [`Subscriber`]: tracing_core::Subscriber
34 subscriber: Option<&'a S>, field
53 S: Subscriber,
55 pub(super) fn new(subscriber: &'a S) -> Self { in new()
57 subscriber: Some(subscriber), in new()
[all …]
Dmod.rs1 //! The [`Layer`] trait, a composable abstraction for building [`Subscriber`]s.
3 //! The [`Subscriber`] trait in `tracing-core` represents the _complete_ set of
5 //! a single `Subscriber` instance is a self-contained implementation of a
7 //! `Subscriber` trait cannot easily be composed with other `Subscriber`s.
9 //! In particular, [`Subscriber`]s are responsible for generating [span IDs] and
12 //! a single `Subscriber` for a given thread at any point in time &mdash;
15 //! On the other hand, the majority of the [`Subscriber`] trait's functionality
19 //! [`Subscriber`] behavior; it can _observe_ events and spans, but does not
25 //! traces, it must be composed with a `Subscriber` in order to be used. The
27 //! definition), representing the types of `Subscriber` they can be composed
[all …]
Dtests.rs2 use tracing_core::subscriber::NoSubscriber;
6 impl<S: Subscriber> Layer<S> for NopLayer {}
10 impl<S: Subscriber> Layer<S> for NopLayer2 {}
16 impl<S: Subscriber> Layer<S> for StringLayer {}
18 impl<S: Subscriber> Layer<S> for StringLayer2 {}
21 impl<S: Subscriber> Layer<S> for StringLayer3 {}
25 impl Subscriber for StringSubscriber {
45 fn assert_subscriber(_s: impl Subscriber) {} in assert_subscriber() argument
46 fn assert_layer<S: Subscriber>(_l: &impl Layer<S>) {} in assert_layer()
92 .with_subscriber(StringSubscriber("subscriber")); in downcasts_to_subscriber()
[all …]
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/20/libcore/ojluni/src/main/java/java/util/concurrent/
DSubmissionPublisher.java49 import static java.util.concurrent.Flow.Subscriber;
55 * current subscriber receives newly submitted items in the same order
71 * at different rates. Each subscriber uses an independent buffer.
86 * access by each subscriber. But reported estimates of lag and demand
97 * <p>If any Subscriber method throws an exception, its subscription
100 * {@link Flow.Subscriber#onNext onNext}, but exceptions in methods
101 * {@link Flow.Subscriber#onSubscribe onSubscribe},
102 * {@link Flow.Subscriber#onError(Throwable) onError} and
103 * {@link Flow.Subscriber#onComplete() onComplete} are not recorded or
113 * common case in which the only action of a subscriber is to request
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/
H A DByteBuffersAsyncRequestBodyTest.java33 import org.reactivestreams.Subscriber;
40 private static class TestSubscriber implements Subscriber<ByteBuffer> {
76 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompleted() local
77 requestBody.subscribe(subscriber); in subscriberIsMarkedAsCompleted()
78 subscriber.request(1); in subscriberIsMarkedAsCompleted()
80 assertTrue(subscriber.onCompleteCalled); in subscriberIsMarkedAsCompleted()
81 assertEquals(1, subscriber.publishedResults.size()); in subscriberIsMarkedAsCompleted()
88 TestSubscriber subscriber = new TestSubscriber(); in subscriberIsMarkedAsCompletedWhenARequestIsMadeForMoreBuffersThanAreAvailable() local
89 requestBody.subscribe(subscriber); in subscriberIsMarkedAsCompletedWhenARequestIsMadeForMoreBuffersThanAreAvailable()
90 subscriber.request(2); in subscriberIsMarkedAsCompletedWhenARequestIsMadeForMoreBuffersThanAreAvailable()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/
H A DHandlerPublisher.java29 import org.reactivestreams.Subscriber;
36 * This publisher supports only one subscriber.
38 …* All interactions with the subscriber are done from the handlers executor, hence, they provide th…
46 …ill release any messages that it drops (for example, messages that are buffered when the subscriber
47 …* cancels), but other than that, it does not release any messages. It is up to the subscriber to …
49 * If the subscriber cancels, the publisher will send a close event up the channel pipeline.
78 …* Whether a subscriber has been provided. This is used to detect whether two subscribers are subsc…
85 private volatile Subscriber<? super T> subscriber; field in HandlerPublisher
96 * @param executor The executor to execute asynchronous events from the subscriber on.
116 * Override to handle when a subscriber cancels the subscription.
[all …]

12345678910>>...85