io.micronaut.kubernetes.client.rxjava3

Class ApiCallbackEmitter<T>

java.lang.Object

io.micronaut.kubernetes.client.rxjava3.ApiCallbackEmitter<T>

Type Parameters:

T - Type

All Implemented Interfaces:

io.kubernetes.client.openapi.ApiCallback<T>

public class ApiCallbackEmitter<T>
extends java.lang.Object
implements io.kubernetes.client.openapi.ApiCallback<T>

Bridges the ApiCallback interface to an RxJava3 SingleEmitter.

Since:

3.3.0

Author:

Nemanja Mikic

Constructor Summary

Constructors

Constructor and Description
ApiCallbackEmitter(io.reactivex.rxjava3.core.SingleEmitter<T> emitter)

Method Summary

Modifier and Type	Method and Description
void	onDownloadProgress(long bytesRead, long contentLength, boolean done)
void	onFailure(io.kubernetes.client.openapi.ApiException e, int statusCode, java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)
void	onSuccess(T result, int statusCode, java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)
void	onUploadProgress(long bytesWritten, long contentLength, boolean done)

Methods inherited from class java.lang.Object

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

Constructor Detail

ApiCallbackEmitter

public ApiCallbackEmitter(io.reactivex.rxjava3.core.SingleEmitter<T> emitter)

Method Detail

onFailure

public void onFailure(io.kubernetes.client.openapi.ApiException e,
                      int statusCode,
                      java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)

Specified by:

onFailure in interface io.kubernetes.client.openapi.ApiCallback<T>

onSuccess

public void onSuccess(T result,
                      int statusCode,
                      java.util.Map<java.lang.String,java.util.List<java.lang.String>> responseHeaders)

Specified by:

onSuccess in interface io.kubernetes.client.openapi.ApiCallback<T>

onUploadProgress

public void onUploadProgress(long bytesWritten,
                             long contentLength,
                             boolean done)

Specified by:

onUploadProgress in interface io.kubernetes.client.openapi.ApiCallback<T>

onDownloadProgress

public void onDownloadProgress(long bytesRead,
                               long contentLength,
                               boolean done)

Specified by:

onDownloadProgress in interface io.kubernetes.client.openapi.ApiCallback<T>