|
|||||||||
上一个软件包 下一个软件包 | 框架 无框架 |
请参见:
描述
类摘要 | |
---|---|
BlockingReadHandler<E> | 模拟缓冲读操作.该处理器存储所有接收到的消息到一个BlockingQueue 并当BlockingReadHandler.read() 、
BlockingReadHandler.read(long, TimeUnit) 、BlockingReadHandler.readEvent() 或
BlockingReadHandler.readEvent(long, TimeUnit) 方法被调用时返回这些消息. |
BufferedWriteHandler | 模拟缓冲写操作.该处理器存储所有写请求到一个为绑定的Queue 并当BufferedWriteHandler.flush() 方法被调用时刷新它们到下游. |
异常摘要 | |
---|---|
BlockingReadTimeoutException | 当在一定的时间周期内没有数据被读取由BlockingReadHandler 抛出的IOException . |
特殊用途的处理器,存储一个事件到内部队列代替直接传播事件..
|
|||||||||
上一个软件包 下一个软件包 | 框架 无框架 |