Uses of Class
com.github.mizosoft.methanol.internal.flow.ForwardingSubscriber

Packages that use ForwardingSubscriber

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

Uses of ForwardingSubscriber in com.github.mizosoft.methanol.internal.extensions

Subclasses of ForwardingSubscriber in com.github.mizosoft.methanol.internal.extensions

Modifier and Type	Class	Description
final class	AsyncSubscriberAdapter<T,S extends Flow.Subscriber<? super List<ByteBuffer>>>	Adapts a subscriber to a BodySubscriber where the body's completion need not be in accordance with onComplete or onError.
class	ForwardingBodySubscriber<T>
final class	TimeoutBodySubscriber<T>

Uses of ForwardingSubscriber in com.github.mizosoft.methanol.internal.flow

Subclasses of ForwardingSubscriber in com.github.mizosoft.methanol.internal.flow

Modifier and Type	Class	Description
class	SerializedForwardingSubscriber<T>	A forwarding subscriber that ensures the delegate isn't called concurrently.
class	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.