org.voovan.http.client

Class AsyncHandler

java.lang.Object

org.voovan.http.client.AsyncHandler

All Implemented Interfaces:

IoHandler

public class AsyncHandler
extends Object
implements IoHandler

HttpClient 异步 IoHandler 实现

Field Summary

Fields

Modifier and Type	Field and Description
Consumer<Response>	async
HttpClient	httpClient
boolean	running
SynchronousHandler	synchronousHandler

Constructor Summary

Constructors

Constructor and Description
AsyncHandler(HttpClient httpClient)

Method Summary

Modifier and Type	Method and Description
Consumer<Response>	getAsync()
boolean	isRunning()
Object	onConnect(IoSession session) 连接成功事件
void	onDisconnect(IoSession session) 连接断开事件
void	onException(IoSession session, Exception e) 异常事件
void	onFlush(IoSession session) Socket 缓冲区发送事件
void	onIdle(IoSession session) 空闲事件
Object	onReceive(IoSession session, Object obj) 接收数据事件
void	onSent(IoSession session, Object obj) 发送数据事件 发送后调用
void	setAsync(Consumer<Response> async)

Methods inherited from class java.lang.Object

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

Field Detail

httpClient

public HttpClient httpClient

async

public Consumer<Response> async

running

public boolean running

synchronousHandler

public SynchronousHandler synchronousHandler

Constructor Detail

AsyncHandler

public AsyncHandler(HttpClient httpClient)

Method Detail

getAsync

public Consumer<Response> getAsync()

setAsync

public void setAsync(Consumer<Response> async)

isRunning

public boolean isRunning()

onConnect

public Object onConnect(IoSession session)

Description copied from interface: IoHandler

连接成功事件

Specified by:

onConnect in interface IoHandler

Parameters:

session - Session 对象

Returns:

返回的对象将发送

onDisconnect

public void onDisconnect(IoSession session)

Description copied from interface: IoHandler

连接断开事件

Specified by:

onDisconnect in interface IoHandler

Parameters:

session - Session 对象

onReceive

public Object onReceive(IoSession session,
                        Object obj)

Description copied from interface: IoHandler

接收数据事件

Specified by:

onReceive in interface IoHandler

Parameters:

session - Session 对象

obj - 接收的对象

Returns:

返回的对象将发送

onSent

public void onSent(IoSession session,
                   Object obj)

Description copied from interface: IoHandler

发送数据事件 发送后调用

Specified by:

onSent in interface IoHandler

Parameters:

session - Session 对象

obj - 发送的对象

onFlush

public void onFlush(IoSession session)

Description copied from interface: IoHandler

Socket 缓冲区发送事件

Specified by:

onFlush in interface IoHandler

Parameters:

session - session Session 对象

onException

public void onException(IoSession session,
                        Exception e)

Description copied from interface: IoHandler

异常事件

Specified by:

onException in interface IoHandler

Parameters:

session - Session 对象

e - 异常信息

onIdle

public void onIdle(IoSession session)

Description copied from interface: IoHandler

空闲事件

Specified by:

onIdle in interface IoHandler

Parameters:

session - Session 对象