Package tripleo.elijah_durable_congenial.util

Class ObservableCompletableProcess<T>

java.lang.Object
tripleo.elijah_durable_congenial.util.ObservableCompletableProcess<T>
All Implemented Interfaces:
io.reactivex.rxjava3.core.Observer<T>
public class ObservableCompletableProcess<T> extends Object implements io.reactivex.rxjava3.core.Observer<T>

  • Constructor Details

    • ObservableCompletableProcess

      public ObservableCompletableProcess()

  • Method Details

    • almostComplete

      public void almostComplete()

    • onSubscribe

      public void onSubscribe(@NonNull @NonNull io.reactivex.rxjava3.disposables.Disposable d)
      Specified by:
      onSubscribe in interface io.reactivex.rxjava3.core.Observer<T>

    • onNext

      public void onNext(@NonNull T aT)
      Specified by:
      onNext in interface io.reactivex.rxjava3.core.Observer<T>

    • onError

      public void onError(@NonNull @NonNull Throwable e)
      Specified by:
      onError in interface io.reactivex.rxjava3.core.Observer<T>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface io.reactivex.rxjava3.core.Observer<T>

    • subscribe

      public void subscribe(@NotNull @NotNull io.reactivex.rxjava3.core.Observer<T> aCio)

    • subscribe

      public void subscribe(@NotNull @NotNull CompletableProcess<T> cp)