Package io.micronaut.oraclecloud.clients.reactor

Class AsyncHandlerSink<Req,Res>

java.lang.Object

io.micronaut.oraclecloud.clients.reactor.AsyncHandlerSink<Req,Res>

Type Parameters:

Req - The request type

Res - The response type

All Implemented Interfaces:

com.oracle.bmc.responses.AsyncHandler<Req,Res>

public class AsyncHandlerSink<Req,Res>
extends Object
implements com.oracle.bmc.responses.AsyncHandler<Req,Res>

Bridges the AsyncHandler interface to an RxJava MonoSink.

Since:

2.0.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor	Description
AsyncHandlerSink(reactor.core.publisher.MonoSink<Res> emitter)

Method Summary

Modifier and Type	Method	Description
void	onError(Req req, Throwable error)
void	onSuccess(Req req, Res res)

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncHandlerSink

public AsyncHandlerSink(reactor.core.publisher.MonoSink<Res> emitter)

Method Details

onSuccess

public void onSuccess(Req req,
 Res res)

Specified by:

onSuccess in interface com.oracle.bmc.responses.AsyncHandler<Req,Res>

onError

public void onError(Req req,
 Throwable error)

Specified by:

onError in interface com.oracle.bmc.responses.AsyncHandler<Req,Res>