Package org.glassfish.jersey.internal.jsr166
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).
-
ClassDescriptionInterrelated interfaces and static methods for establishing flow-controlled components in which
Publishers
produce items consumed by one or moreSubscribers
, each managed by aSubscription
.Flow.Processor<T,R> A component that acts as both a Subscriber and Publisher.A producer of items (and related control messages) received by Subscribers.A receiver of messages.Message control linking aFlow.Publisher
andFlow.Subscriber
.AFlow.Publisher
that asynchronously issues submitted (non-null) items to current subscribers until it is closed.A bounded (ring) buffer with integrated control to start a consumer task whenever items are available.Subscriber for method consumeA task for consuming buffer items and signals, created and executed whenever they become available.Fallback if ForkJoinPool.commonPool() cannot support parallelismHelper for classes in the jsr166 package to access thesun.misc.Unsafe
instance.