Package | Description |
---|---|
org.glassfish.jersey.internal.jsr166 |
Contains a subset of classes repackaged from the jsr166 written by Doug Lea.
|
org.glassfish.jersey.internal.util |
Common Jersey internal miscellaneous utility classes.
|
org.glassfish.jersey.microprofile.restclient |
Modifier and Type | Interface and Description |
---|---|
static interface |
Flow.Processor<T,R>
A component that acts as both a Subscriber and Publisher.
|
interface |
JerseyFlowSubscriber<T> |
Modifier and Type | Method and Description |
---|---|
void |
SubmissionPublisher.subscribe(Flow.Subscriber<? super T> subscriber)
Adds the given Subscriber unless already subscribed.
|
void |
Flow.Publisher.subscribe(Flow.Subscriber<? super T> subscriber)
Adds the given Subscriber if possible.
|
void |
SubmittableFlowPublisher.subscribe(Flow.Subscriber<? super T> subscriber)
Adds the given Subscriber unless already subscribed.
|
Modifier and Type | Method and Description |
---|---|
static <T> SubmittableFlowPublisher<T> |
SubmissionPublisherFactory.createSubmissionPublisher(Executor executor,
int maxBufferCapacity,
BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)
Creates a new SubmittableFlowPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and, if non-null, the given handler invoked
when any Subscriber throws an exception in method
onNext . |
int |
SubmissionPublisher.offer(T item,
BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber
by asynchronously invoking its
onNext method. |
int |
SubmittableFlowPublisher.offer(T item,
BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber
by asynchronously invoking its
onNext method. |
int |
SubmissionPublisher.offer(T item,
long timeout,
TimeUnit unit,
BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber
by asynchronously invoking its
onNext method, blocking while
resources for any subscription are unavailable, up to the
specified timeout or until the caller thread is interrupted, at
which point the given handler (if non-null) is invoked, and if it
returns true, retried once. |
int |
SubmittableFlowPublisher.offer(T item,
long timeout,
TimeUnit unit,
BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)
Publishes the given item, if possible, to each current subscriber
by asynchronously invoking its
onNext method, blocking while
resources for any subscription are unavailable, up to the
specified timeout or until the caller thread is interrupted, at
which point the given handler (if non-null) is invoked, and if it
returns true, retried once. |
Constructor and Description |
---|
SubmissionPublisher(Executor executor,
int maxBufferCapacity,
BiConsumer<? super Flow.Subscriber<? super T>,? super Throwable> handler)
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and, if non-null, the given handler invoked
when any Subscriber throws an exception in method
onNext . |
Modifier and Type | Class and Description |
---|---|
class |
JerseyPublisher.SubscriberWrapper<T> |
Modifier and Type | Method and Description |
---|---|
Flow.Subscriber<? super T> |
JerseyPublisher.SubscriberWrapper.getWrappedSubscriber() |
Modifier and Type | Method and Description |
---|---|
void |
JerseyPublisher.subscribe(Flow.Subscriber<? super T> subscriber) |
Constructor and Description |
---|
SubscriberWrapper(Flow.Subscriber<? super T> subscriber) |
Modifier and Type | Class and Description |
---|---|
class |
SseEventSuscriber<T> |
Copyright © 2007-2024, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.