com.swak.http.reactor.sink

类 AbstractSinkAsyncHandlerBridge<T>

java.lang.Object

com.swak.http.reactor.sink.AbstractSinkAsyncHandlerBridge<T>

所有已实现的接口:

org.asynchttpclient.AsyncHandler<Void>

直接已知子类:

AbstractSinkProgressAsyncHandlerBridge, SinkAsyncHandlerBridge

public abstract class AbstractSinkAsyncHandlerBridge<T>
extends Object
implements org.asynchttpclient.AsyncHandler<Void>

嵌套类概要

从接口继承的嵌套类/接口 org.asynchttpclient.AsyncHandler

org.asynchttpclient.AsyncHandler.State

字段概要

字段

限定符和类型	字段和说明
protected com.swak.reactor.publisher.DisposableMonoSink<T>	emitter The Rx callback object that receives downstream events and will be queried for its disposed state when Async HTTP Client callbacks are invoked.

构造器概要

构造器

限定符	构造器和说明
protected	AbstractSinkAsyncHandlerBridge(com.swak.reactor.publisher.DisposableMonoSink<T> emitter)

方法概要

限定符和类型	方法和说明
protected abstract org.asynchttpclient.AsyncHandler<? extends T>	delegate()
protected org.asynchttpclient.AsyncHandler.State	disposed() Called to indicate that request processing is to be aborted because the linked Rx stream has been disposed.
org.asynchttpclient.AsyncHandler.State	onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart content)
Void	onCompleted() The value returned by the wrapped AsyncHandler won't be returned by this method, but emtited via RxJava.
org.asynchttpclient.AsyncHandler.State	onHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)
org.asynchttpclient.AsyncHandler.State	onStatusReceived(org.asynchttpclient.HttpResponseStatus status)
void	onThrowable(Throwable t) The exception will first be propagated to the wrapped AsyncHandler, then emitted via RxJava.
org.asynchttpclient.AsyncHandler.State	onTrailingHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)

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

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

从接口继承的方法 org.asynchttpclient.AsyncHandler

onConnectionOffer, onConnectionPoolAttempt, onConnectionPooled, onHostnameResolutionAttempt, onHostnameResolutionFailure, onHostnameResolutionSuccess, onRequestSend, onRetry, onTcpConnectAttempt, onTcpConnectFailure, onTcpConnectSuccess, onTlsHandshakeAttempt, onTlsHandshakeFailure, onTlsHandshakeSuccess

字段详细资料

emitter

protected final com.swak.reactor.publisher.DisposableMonoSink<T> emitter

The Rx callback object that receives downstream events and will be queried for its disposed state when Async HTTP Client callbacks are invoked.

构造器详细资料

AbstractSinkAsyncHandlerBridge

protected AbstractSinkAsyncHandlerBridge(com.swak.reactor.publisher.DisposableMonoSink<T> emitter)

方法详细资料

onBodyPartReceived

public final org.asynchttpclient.AsyncHandler.State onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart content)
                                                                throws Exception

指定者:

onBodyPartReceived 在接口中 org.asynchttpclient.AsyncHandler<Void>

抛出:

Exception

onStatusReceived

public final org.asynchttpclient.AsyncHandler.State onStatusReceived(org.asynchttpclient.HttpResponseStatus status)
                                                              throws Exception

指定者:

onStatusReceived 在接口中 org.asynchttpclient.AsyncHandler<Void>

抛出:

Exception

onHeadersReceived

public final org.asynchttpclient.AsyncHandler.State onHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)
                                                               throws Exception

指定者:

onHeadersReceived 在接口中 org.asynchttpclient.AsyncHandler<Void>

抛出:

Exception

onTrailingHeadersReceived

public org.asynchttpclient.AsyncHandler.State onTrailingHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)
                                                                 throws Exception

指定者:

onTrailingHeadersReceived 在接口中 org.asynchttpclient.AsyncHandler<Void>

抛出:

Exception

onCompleted

public final Void onCompleted()

The value returned by the wrapped AsyncHandler won't be returned by this method, but emtited via RxJava.

指定者:

onCompleted 在接口中 org.asynchttpclient.AsyncHandler<Void>

返回:

always null

onThrowable

public final void onThrowable(Throwable t)

The exception will first be propagated to the wrapped AsyncHandler, then emitted via RxJava. If the invocation of the delegate itself throws an exception, both the original exception and the follow-up exception will be wrapped into RxJava's CompositeException and then be emitted.

指定者:

onThrowable 在接口中 org.asynchttpclient.AsyncHandler<Void>

disposed

protected final org.asynchttpclient.AsyncHandler.State disposed()

Called to indicate that request processing is to be aborted because the linked Rx stream has been disposed. If the delegate didn't already receive a terminal event, AsyncHandler#onThrowable(Throwable) onThrowable will be called with a DisposedException.

返回:

always State#ABORT

delegate

protected abstract org.asynchttpclient.AsyncHandler<? extends T> delegate()

返回:

the wrapped AsyncHandler instance to which calls are delegated