private static class ReactiveTypeHandler.SseEmitterSubscriber extends ReactiveTypeHandler.AbstractEmitterSubscriber
Constructor and Description |
---|
SseEmitterSubscriber(SseEmitter sseEmitter,
TaskExecutor executor) |
Modifier and Type | Method and Description |
---|---|
private SseEmitter.SseEventBuilder |
adapt(ServerSentEvent<?> sse) |
protected void |
send(java.lang.Object element) |
connect, getEmitter, onComplete, onError, onNext, onSubscribe, run
SseEmitterSubscriber(SseEmitter sseEmitter, TaskExecutor executor)
protected void send(java.lang.Object element) throws java.io.IOException
send
in class ReactiveTypeHandler.AbstractEmitterSubscriber
java.io.IOException
private SseEmitter.SseEventBuilder adapt(ServerSentEvent<?> sse)