Package io.servicetalk.concurrent.internal

Class EmptySubscriptions

java.lang.Object

io.servicetalk.concurrent.internal.EmptySubscriptions

public final class EmptySubscriptions
extends Object

Utility methods for PublisherSource.Subscriptions which don't deliver any data.

Field Summary

Fields

Modifier and Type	Field	Description
static final PublisherSource.Subscription	EMPTY_SUBSCRIPTION	A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will throw on invalid demand.
static final PublisherSource.Subscription	EMPTY_SUBSCRIPTION_NO_THROW	A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will not throw on invalid demand.

Method Summary

Modifier and Type	Method	Description
static PublisherSource.Subscription	newEmptySubscription()	Create an empty PublisherSource.Subscription that will throw on invalid demand.
static <T> PublisherSource.Subscription	newEmptySubscription(PublisherSource.Subscriber<T> subscriber)	Create an empty PublisherSource.Subscription that will propagate an error to a PublisherSource.Subscriber upon invalid demand.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

EMPTY_SUBSCRIPTION

public static final PublisherSource.Subscription EMPTY_SUBSCRIPTION

A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will throw on invalid demand.

EMPTY_SUBSCRIPTION_NO_THROW

public static final PublisherSource.Subscription EMPTY_SUBSCRIPTION_NO_THROW

A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will not throw on invalid demand.

Method Details

newEmptySubscription

public static <T> PublisherSource.Subscription newEmptySubscription(PublisherSource.Subscriber<T> subscriber)

Create an empty PublisherSource.Subscription that will propagate an error to a PublisherSource.Subscriber upon invalid demand.

Type Parameters:

T - The type of PublisherSource.Subscriber.

Parameters:

subscriber - The subscriber to propagate

Returns:

An empty PublisherSource.Subscription that will propagate an error to a PublisherSource.Subscriber upon invalid demand.

newEmptySubscription

public static PublisherSource.Subscription newEmptySubscription()

Create an empty PublisherSource.Subscription that will throw on invalid demand.

Returns:

A PublisherSource.Subscription that will throw on invalid demand.