reactor.core.publisher

类 BaseSubscriber<T>

java.lang.Object

reactor.core.publisher.BaseSubscriber<T>

所有已实现的接口:

org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription, CoreSubscriber<T>, Disposable

public abstract class BaseSubscriber<T>
extends java.lang.Object
implements CoreSubscriber<T>, org.reactivestreams.Subscription, Disposable

A simple base class for a Subscriber implementation that lets the user perform a request(long) and cancel() on it directly. As the targeted use case is to manually handle requests, the hookOnSubscribe(Subscription) and hookOnNext(Object) hooks are expected to be implemented, but they nonetheless default to an unbounded request at subscription time. If you need to define a Context for this BaseSubscriber, simply override its CoreSubscriber.currentContext() method.

Override the other optional hooks hookOnComplete(), hookOnError(Throwable) and hookOnCancel() to customize the base behavior. You also have a termination hook, hookFinally(SignalType).

Most of the time, exceptions triggered inside hooks are propagated to onError(Throwable) (unless there is a fatal exception). The class is in the reactor.core.publisher package, as this subscriber is tied to a single Publisher.

作者:

Simon Baslé

嵌套类概要

从接口继承的嵌套类/接口 reactor.core.Disposable

Disposable.Composite, Disposable.Swap

构造器概要

构造器

构造器和说明
BaseSubscriber()

方法概要

限定符和类型	方法和说明
void	cancel()
void	dispose() Dispose the Subscription by cancelling it.
boolean	isDisposed() Optionally return true when the resource or task is disposed.
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(T value)
void	onSubscribe(org.reactivestreams.Subscription s) Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long).
void	request(long n)
void	requestUnbounded() Request an unbounded amount.
java.lang.String	toString()

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 reactor.core.CoreSubscriber

currentContext

构造器详细资料

BaseSubscriber

public BaseSubscriber()

方法详细资料

isDisposed

public boolean isDisposed()

从接口复制的说明: Disposable

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

指定者:

isDisposed 在接口中 Disposable

返回:

true when there's a guarantee the resource or task is disposed.

dispose

public void dispose()

Dispose the Subscription by cancelling it.

指定者:

dispose 在接口中 Disposable

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription s)

从接口复制的说明: CoreSubscriber

Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long). Should further onNext related state modification occur, thread-safety will be required.

Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled Logger.

指定者:

onSubscribe 在接口中 org.reactivestreams.Subscriber<T>

指定者:

onSubscribe 在接口中 CoreSubscriber<T>

onNext

public final void onNext(T value)

指定者:

onNext 在接口中 org.reactivestreams.Subscriber<T>

onError

public final void onError(java.lang.Throwable t)

指定者:

onError 在接口中 org.reactivestreams.Subscriber<T>

onComplete

public final void onComplete()

指定者:

onComplete 在接口中 org.reactivestreams.Subscriber<T>

request

public final void request(long n)

指定者:

request 在接口中 org.reactivestreams.Subscription

requestUnbounded

public final void requestUnbounded()

Request an unbounded amount.

cancel

public final void cancel()

指定者:

cancel 在接口中 org.reactivestreams.Subscription

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object