Module methanol

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

package com.github.mizosoft.methanol.internal.flow

Related Packages

Package	Description
com.github.mizosoft.methanol.internal

Classes

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 prefetches items from upstream and maintains a certain number of .
SerializedForwardingSubscriber<T>	A forwarding subscriber that ensures the delegate isn't called concurrently.
TimeoutSubscriber<T,S extends 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.