com.swak.http.reactor

类 DefaultReactorHttpClient

java.lang.Object

com.swak.http.reactor.DefaultReactorHttpClient

所有已实现的接口:

ReactorHttpClient

public class DefaultReactorHttpClient
extends Object
implements ReactorHttpClient

响应式的 http 客户端

作者:

lifeng

方法概要

限定符和类型	方法和说明
protected <T> org.asynchttpclient.AsyncHandler<?>	createBridge(DisposableMonoSink<T> emitter, org.asynchttpclient.AsyncHandler<T> handler) Creates an AsyncHandler that bridges events from the given handler to the given emitter and cancellation/disposal in the other direction.
<T> reactor.core.publisher.Mono<T>	prepare(org.asynchttpclient.Request request, org.asynchttpclient.AsyncHandler<T> handler) disposable 主要监控 是否取消， 取消之后 AsyncHandler 怎么应对 onDispose 是一个回调， 会通过 disposable 来 取消 disposable 中需要取消的资源 -- 上层不会取消, 做一个简单的监控

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

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

从接口继承的方法 com.swak.http.reactor.ReactorHttpClient

create

方法详细资料

prepare

public <T> reactor.core.publisher.Mono<T> prepare(org.asynchttpclient.Request request,
                                                  org.asynchttpclient.AsyncHandler<T> handler)

disposable 主要监控 是否取消， 取消之后 AsyncHandler 怎么应对 onDispose 是一个回调， 会通过 disposable 来 取消 disposable 中需要取消的资源 -- 上层不会取消, 做一个简单的监控

指定者:

prepare 在接口中 ReactorHttpClient

类型参数:

T - the result type produced by handlers produced by handlerSupplier and emitted by the returned Maybe instance

参数:

request - the request that is to be executed

返回:

a Maybe that executes request upon subscription and that emits the results produced by the supplied handers

createBridge

protected <T> org.asynchttpclient.AsyncHandler<?> createBridge(DisposableMonoSink<T> emitter,
                                                               org.asynchttpclient.AsyncHandler<T> handler)

Creates an AsyncHandler that bridges events from the given handler to the given emitter and cancellation/disposal in the other direction.

类型参数:

T - the result type produced by handler and emitted by emitter

参数:

emitter - the RxJava emitter instance that receives results upon completion and will be queried for disposal during event processing

handler - the AsyncHandler instance that receives downstream events and produces the result that will be emitted upon request completion

返回:

the bridge handler