Class ObservableBodyBinder
java.lang.Object
io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder
- All Implemented Interfaces:
io.micronaut.core.bind.annotation.AnnotatedArgumentBinder<io.micronaut.http.annotation.Body,
,io.reactivex.Observable, io.micronaut.http.HttpRequest<?>> io.micronaut.core.bind.ArgumentBinder<io.reactivex.Observable,
,io.micronaut.http.HttpRequest<?>> io.micronaut.core.bind.TypeArgumentBinder<io.reactivex.Observable,
,io.micronaut.http.HttpRequest<?>> io.micronaut.http.bind.binders.AnnotatedRequestArgumentBinder<io.micronaut.http.annotation.Body,
,io.reactivex.Observable> io.micronaut.http.bind.binders.BodyArgumentBinder<io.reactivex.Observable>
,io.micronaut.http.bind.binders.NonBlockingBodyArgumentBinder<io.reactivex.Observable>
,io.micronaut.http.bind.binders.RequestArgumentBinder<io.reactivex.Observable>
,io.micronaut.http.bind.binders.TypedRequestArgumentBinder<io.reactivex.Observable>
@Internal
public class ObservableBodyBinder
extends Object
implements io.micronaut.http.bind.binders.NonBlockingBodyArgumentBinder<io.reactivex.Observable>
Bindings
Body
arguments of type Observable
.- Since:
- 1.0
- Author:
- Graeme Rocher
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.micronaut.core.bind.ArgumentBinder
io.micronaut.core.bind.ArgumentBinder.BindingResult<T extends Object>
-
Field Summary
Modifier and TypeFieldDescriptionstatic final io.micronaut.core.type.Argument<io.reactivex.Observable>
-
Constructor Summary
ConstructorDescriptionObservableBodyBinder
(io.micronaut.http.bind.binders.BodyArgumentBinder<org.reactivestreams.Publisher<Object>> publisherBodyBinder) -
Method Summary
Modifier and TypeMethodDescriptionio.micronaut.core.type.Argument<io.reactivex.Observable>
io.micronaut.core.bind.ArgumentBinder.BindingResult<io.reactivex.Observable>
bind
(io.micronaut.core.convert.ArgumentConversionContext<io.reactivex.Observable> context, io.micronaut.http.HttpRequest<?> source) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.micronaut.http.bind.binders.BodyArgumentBinder
getAnnotationType
Methods inherited from interface io.micronaut.http.bind.binders.TypedRequestArgumentBinder
matches
-
Field Details
-
TYPE
public static final io.micronaut.core.type.Argument<io.reactivex.Observable> TYPE
-
-
Constructor Details
-
ObservableBodyBinder
public ObservableBodyBinder(io.micronaut.http.bind.binders.BodyArgumentBinder<org.reactivestreams.Publisher<Object>> publisherBodyBinder) - Parameters:
publisherBodyBinder
- the publisher body binder
-
-
Method Details
-
superTypes
- Specified by:
superTypes
in interfaceio.micronaut.http.bind.binders.TypedRequestArgumentBinder<io.reactivex.Observable>
-
argumentType
public io.micronaut.core.type.Argument<io.reactivex.Observable> argumentType()- Specified by:
argumentType
in interfaceio.micronaut.core.bind.TypeArgumentBinder<io.reactivex.Observable,
io.micronaut.http.HttpRequest<?>>
-
bind
public io.micronaut.core.bind.ArgumentBinder.BindingResult<io.reactivex.Observable> bind(io.micronaut.core.convert.ArgumentConversionContext<io.reactivex.Observable> context, io.micronaut.http.HttpRequest<?> source) - Specified by:
bind
in interfaceio.micronaut.core.bind.ArgumentBinder<io.reactivex.Observable,
io.micronaut.http.HttpRequest<?>>
-