@Singleton
@Requires(classes=io.reactivex.Flowable.class)
@Internal
@Indexed(value=io.micronaut.http.client.ReactiveClientResultTransformer.class)
public class RxReactiveClientResultTransformer
extends java.lang.Object
implements io.micronaut.http.client.ReactiveClientResultTransformer
Maybe
to handle NOT_FOUND results.Constructor and Description |
---|
RxReactiveClientResultTransformer() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
transform(java.lang.Object publisherResult) |