Class ApiCallbackEmitter<T>

java.lang.Object
io.micronaut.kubernetes.client.rxjava2.ApiCallbackEmitter<T>
Type Parameters:
T - Type
All Implemented Interfaces:
io.kubernetes.client.openapi.ApiCallback<T>

public class ApiCallbackEmitter<T> extends Object implements io.kubernetes.client.openapi.ApiCallback<T>
Bridges the ApiCallback interface to an RxJava2 SingleEmitter.
Since:
3.0
Author:
Pavol Gressa
  • Constructor Details

    • ApiCallbackEmitter

      public ApiCallbackEmitter(io.reactivex.SingleEmitter<T> emitter)
  • Method Details

    • onFailure

      public void onFailure(io.kubernetes.client.openapi.ApiException e, int statusCode, Map<String,List<String>> responseHeaders)
      Specified by:
      onFailure in interface io.kubernetes.client.openapi.ApiCallback<T>
    • onSuccess

      public void onSuccess(T result, int statusCode, Map<String,List<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>