io.micronaut.oraclecloud.clients.rxjava

Class AsyncHandlerEmitter<Req,Res>

java.lang.Object

io.micronaut.oraclecloud.clients.rxjava.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 java.lang.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 and Description
AsyncHandlerEmitter(io.reactivex.SingleEmitter<Res> emitter)

Method Summary

Modifier and Type	Method and Description
void	onError(Req req, java.lang.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 Detail

AsyncHandlerEmitter

public AsyncHandlerEmitter(io.reactivex.SingleEmitter<Res> emitter)

Method Detail

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,
                    java.lang.Throwable error)

Specified by:

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