@Singleton @Requires(classes=io.reactivex.Observable.class) @Internal public class ObservableBodyBinder extends DefaultBodyAnnotationBinder<io.reactivex.Observable> implements NonBlockingBodyArgumentBinder<io.reactivex.Observable>
Body
arguments of type Observable
.ArgumentBinder.BindingResult<T>
Modifier and Type | Field and Description |
---|---|
static Argument<io.reactivex.Observable> |
TYPE |
conversionService
Constructor and Description |
---|
ObservableBodyBinder(ConversionService conversionService,
BeanLocator beanLocator,
HttpServerConfiguration httpServerConfiguration) |
Modifier and Type | Method and Description |
---|---|
Argument<io.reactivex.Observable> |
argumentType() |
ArgumentBinder.BindingResult<io.reactivex.Observable> |
bind(ArgumentConversionContext<io.reactivex.Observable> context,
HttpRequest<?> source)
Bind the given argument from the given source.
|
getAnnotationType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAnnotationType
of
public static final Argument<io.reactivex.Observable> TYPE
public ObservableBodyBinder(ConversionService conversionService, BeanLocator beanLocator, HttpServerConfiguration httpServerConfiguration)
conversionService
- The conversion servicebeanLocator
- The bean locatorhttpServerConfiguration
- The Http server configurationpublic Argument<io.reactivex.Observable> argumentType()
argumentType
in interface TypeArgumentBinder<io.reactivex.Observable,HttpRequest<?>>
public ArgumentBinder.BindingResult<io.reactivex.Observable> bind(ArgumentConversionContext<io.reactivex.Observable> context, HttpRequest<?> source)
ArgumentBinder
bind
in interface ArgumentBinder<io.reactivex.Observable,HttpRequest<?>>
bind
in class DefaultBodyAnnotationBinder<io.reactivex.Observable>
context
- The ArgumentConversionContext
source
- The sourceOptional
of the value. If no binding was possible Optional.empty()