Package io.micronaut.oraclecloud.clients.rxjava2

Class AsyncHandlerEmitter<Req,Res>

java.lang.Object

io.micronaut.oraclecloud.clients.rxjava2.AsyncHandlerEmitter<Req,Res>

Type Parameters:

Req - The request type

Res - The response type

All Implemented Interfaces:

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

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

Bridges the AsyncHandler interface to an RxJava SingleEmitter.

Since:

1.0.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor	Description
AsyncHandlerEmitter(io.reactivex.SingleEmitter<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

AsyncHandlerEmitter

public AsyncHandlerEmitter(io.reactivex.SingleEmitter<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>