Package org.glassfish.jersey.internal.jsr166
Contains a subset of classes repackaged from the jsr166 written by Doug Lea.
The subset contains JDK 9 Flow API (reactive streams).
-
Interface Summary Interface Description Flow.Processor<T,R> A component that acts as both a Subscriber and Publisher.Flow.Publisher<T> A producer of items (and related control messages) received by Subscribers.Flow.Subscriber<T> A receiver of messages.Flow.Subscription Message control linking aFlow.Publisher
andFlow.Subscriber
. -
Class Summary Class Description Flow Interrelated interfaces and static methods for establishing flow-controlled components in whichPublishers
produce items consumed by one or moreSubscribers
, each managed by aSubscription
.SubmissionPublisher<T> AFlow.Publisher
that asynchronously issues submitted (non-null) items to current subscribers until it is closed.SubmissionPublisher.BufferedSubscription<T> A bounded (ring) buffer with integrated control to start a consumer task whenever items are available.SubmissionPublisher.ConsumerSubscriber<T> Subscriber for method consumeSubmissionPublisher.ConsumerTask<T> A task for consuming buffer items and signals, created and executed whenever they become available.SubmissionPublisher.ThreadPerTaskExecutor Fallback if ForkJoinPool.commonPool() cannot support parallelismUnsafeAccessor Helper for classes in the jsr166 package to access thesun.misc.Unsafe
instance.