private static class ReactiveTypeHandler.DeferredResultSubscriber
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
multiValueSource |
private DeferredResult<java.lang.Object> |
result |
private ReactiveTypeHandler.CollectedValuesList |
values |
Constructor and Description |
---|
DeferredResultSubscriber(DeferredResult<java.lang.Object> result,
ReactiveAdapter adapter,
ResolvableType elementType) |
Modifier and Type | Method and Description |
---|---|
void |
connect(ReactiveAdapter adapter,
java.lang.Object returnValue) |
void |
onComplete() |
void |
onError(java.lang.Throwable ex) |
void |
onNext(java.lang.Object element) |
void |
onSubscribe(Subscription subscription) |
private final DeferredResult<java.lang.Object> result
private final boolean multiValueSource
private final ReactiveTypeHandler.CollectedValuesList values
DeferredResultSubscriber(DeferredResult<java.lang.Object> result, ReactiveAdapter adapter, ResolvableType elementType)
public void connect(ReactiveAdapter adapter, java.lang.Object returnValue)
public void onSubscribe(Subscription subscription)
public void onNext(java.lang.Object element)
public void onError(java.lang.Throwable ex)
public void onComplete()