private static class ReactiveTypeHandler.JsonEmitterSubscriber extends ReactiveTypeHandler.AbstractEmitterSubscriber
Constructor and Description |
---|
JsonEmitterSubscriber(ResponseBodyEmitter emitter,
TaskExecutor executor) |
Modifier and Type | Method and Description |
---|---|
protected void |
send(java.lang.Object element) |
connect, getEmitter, onComplete, onError, onNext, onSubscribe, run
JsonEmitterSubscriber(ResponseBodyEmitter emitter, TaskExecutor executor)
protected void send(java.lang.Object element) throws java.io.IOException
send
in class ReactiveTypeHandler.AbstractEmitterSubscriber
java.io.IOException