Module methanol.testing

Package com.github.mizosoft.methanol.testing

Class SubmittableSubscription<T>

java.lang.Object

com.github.mizosoft.methanol.internal.flow.AbstractSubscription<T>

com.github.mizosoft.methanol.internal.flow.AbstractPollableSubscription<T>

com.github.mizosoft.methanol.internal.flow.AbstractQueueSubscription<T>

com.github.mizosoft.methanol.testing.SubmittableSubscription<T>

All Implemented Interfaces:

Flow.Subscription

public final class SubmittableSubscription<T>
extends AbstractQueueSubscription<T>

A subscription that publishes submitted items.

Constructor Summary

Constructors

Constructor	Description
SubmittableSubscription(Flow.Subscriber<? super T> downstream, Executor executor)

Method Summary

Modifier and Type	Method	Description
protected void	abort(boolean flowInterrupted)	Releases resources held by this subscription.
int	abortCount()
void	awaitAbort()
void	complete()
long	currentDemand()
boolean	flowInterrupted()
void	submit(T item)
void	submitSilently(T item)

Methods inherited from class com.github.mizosoft.methanol.internal.flow.AbstractQueueSubscription

isComplete, poll, submitAndComplete

Methods inherited from class com.github.mizosoft.methanol.internal.flow.AbstractPollableSubscription

emit

Methods inherited from class com.github.mizosoft.methanol.internal.flow.AbstractSubscription

cancel, cancelOnComplete, cancelOnError, fireOrKeepAlive, fireOrKeepAliveOnError, fireOrKeepAliveOnNext, hasPendingErrors, isCancelled, request, submitOnNext

Methods inherited from class java.lang.Object

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

Constructor Details

SubmittableSubscription

public SubmittableSubscription(Flow.Subscriber<? super T> downstream,
 Executor executor)

Method Details

abort

protected void abort(boolean flowInterrupted)

Description copied from class: AbstractSubscription

Releases resources held by this subscription. flowInterrupted tells whether cancellation was due to flow interruption by downstream (e.g. calling cancel() or throwing from onNext or onSubscribe), or due to ending the normal flow of signals (onSubscribe -> onNext* -> (onError | onComplete)).

Overrides:

abort in class AbstractQueueSubscription<T>

awaitAbort

public void awaitAbort()

submit

public void submit(T item)

Overrides:

submit in class AbstractQueueSubscription<T>

submitSilently

public void submitSilently(T item)

Overrides:

submitSilently in class AbstractQueueSubscription<T>

complete

public void complete()

Overrides:

complete in class AbstractQueueSubscription<T>

currentDemand

public long currentDemand()

Overrides:

currentDemand in class AbstractSubscription<T>

abortCount

public int abortCount()

flowInterrupted

public boolean flowInterrupted()