Module methanol

Package com.github.mizosoft.methanol.internal.flow

Class Summary

Class	Description
AbstractPollableSubscription<T>	A subscription that emits items from a pollable source.
AbstractQueueSubscription<T>	A subscription that emits items from a queue and completes downstream as soon as a sentinel value is observed.
AbstractSubscription<T>	An abstract Flow.Subscription that implements most of the machinery for execution and backpressure control.
FlowSupport	Helpers for implementing reactive streams subscriptions and the like.
ForwardingSubscriber<T>	A Subscriber<T> that forwards to a downstream Subscriber<? super T>.
Prefetcher	An object that manages requests to an upstream subscription according to a prefetching policy.
SerializedForwardingSubscriber<T>	A forwarding subscriber that ensures the delegate isn't called concurrently.
TimeoutSubscriber<T,S extends java.util.concurrent.Flow.Subscriber<? super T>>	A subscriber that intercepts requests to upstream and schedules error completion if each requested item isn't received within a timeout.
Upstream	A one-use atomic reference to an upstream subscription.