org.noear.solon.web.sse

类 SseEmitter

java.lang.Object

org.noear.solon.web.sse.SseEmitter

public class SseEmitter
extends java.lang.Object

Sse 发射器（操作界面）

从以下版本开始:

2.3

字段概要

字段

限定符和类型	字段和说明
protected java.lang.Runnable	onCompletion
protected java.util.function.Consumer<java.lang.Throwable>	onError
protected ConsumerEx<SseEmitter>	onInited
protected java.lang.Runnable	onTimeout
protected long	timeout

构造器概要

构造器

构造器和说明
SseEmitter(long timeout) 超时（用于异步超时）

方法概要

限定符和类型	方法和说明
void	complete() 完成（用于手动控制）
protected void	initialize(SseEmitterHandler handler) 初始化
SseEmitter	onCompletion(java.lang.Runnable onCompletion) 完成回调方法
SseEmitter	onError(java.util.function.Consumer<java.lang.Throwable> onError) 异常回调方法
SseEmitter	onInited(ConsumerEx<SseEmitter> onInited) 初始化回调方法
SseEmitter	onTimeout(java.lang.Runnable onTimeout) 超时回调方法
void	send(SseEvent event) 发送事件
void	send(java.lang.String data) 发送事件内容

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

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

字段详细资料

onCompletion

protected java.lang.Runnable onCompletion

onTimeout

protected java.lang.Runnable onTimeout

onError

protected java.util.function.Consumer<java.lang.Throwable> onError

onInited

protected ConsumerEx<SseEmitter> onInited

timeout

protected long timeout

构造器详细资料

SseEmitter

public SseEmitter(long timeout)

超时（用于异步超时）

方法详细资料

onCompletion

public SseEmitter onCompletion(java.lang.Runnable onCompletion)

完成回调方法

onTimeout

public SseEmitter onTimeout(java.lang.Runnable onTimeout)

超时回调方法

onError

public SseEmitter onError(java.util.function.Consumer<java.lang.Throwable> onError)

异常回调方法

onInited

public SseEmitter onInited(ConsumerEx<SseEmitter> onInited)

初始化回调方法

send

public void send(java.lang.String data)
          throws java.io.IOException

发送事件内容

参数:

data - 事件数据

抛出:

java.io.IOException

send

public void send(SseEvent event)
          throws java.io.IOException

发送事件

参数:

event - 事件数据

抛出:

java.io.IOException

complete

public void complete()

完成（用于手动控制）

initialize

protected void initialize(SseEmitterHandler handler)
                   throws java.lang.Throwable

初始化

抛出:

java.lang.Throwable