io.micronaut.http.client.rxjava2

Class RxReactiveClientResultTransformer

java.lang.Object

io.micronaut.http.client.rxjava2.RxReactiveClientResultTransformer

All Implemented Interfaces:

ReactiveClientResultTransformer

@Singleton
 @Requires(classes=io.reactivex.Flowable.class)
 @Internal
 @Indexed(value=ReactiveClientResultTransformer.class)
public class RxReactiveClientResultTransformer
extends java.lang.Object
implements ReactiveClientResultTransformer

Adds custom support for Maybe to handle NOT_FOUND results.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
RxReactiveClientResultTransformer()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	transform(java.lang.Object publisherResult) Transform the publisher result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxReactiveClientResultTransformer

public RxReactiveClientResultTransformer()

Method Detail

transform

public java.lang.Object transform(java.lang.Object publisherResult)

Description copied from interface: ReactiveClientResultTransformer

Transform the publisher result.

Specified by:

transform in interface ReactiveClientResultTransformer

Parameters:

publisherResult - The publisher result that is an object that conforms to Publishers.isConvertibleToPublisher(Class)

Returns:

The transformed result