Package hu.akarnokd.rxjava3.consumers

Class SingleConsumers

  • public final class SingleConsumers
extends java.lang.Object
    Utility methods for creating and using consumers SingleObservers.
    Since:
    0.18.0

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T> Disposable subscribeAutoDispose​(Single<T> source, CompositeDisposable composite, Consumer<? super T> onSuccess)
      Wraps the given onXXX callbacks into a Disposable Observer, adds it to the given CompositeDisposable and ensures, that if the upstream completes or this particlular Disposable is disposed, the Observer is removed from the given composite.
      static <T> Disposable subscribeAutoDispose​(Single<T> source, CompositeDisposable composite, Consumer<? super T> onSuccess, Consumer<? super java.lang.Throwable> onError)
      Wraps the given onXXX callbacks into a Disposable Observer, adds it to the given CompositeDisposable and ensures, that if the upstream completes or this particlular Disposable is disposed, the Observer is removed from the given composite.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • subscribeAutoDispose

        public static <T> Disposable subscribeAutoDispose​(Single<T> source,
                                                  CompositeDisposable composite,
                                                  Consumer<? super T> onSuccess)
        Wraps the given onXXX callbacks into a Disposable Observer, adds it to the given CompositeDisposable and ensures, that if the upstream completes or this particlular Disposable is disposed, the Observer is removed from the given composite.

        The Observer will be removed after the callback for the terminal event has been invoked.

        Type Parameters:
        T - the value type
        Parameters:
        source - the source SingleObserver to subscribe to.
        composite - the composite Disposable to add and remove the created Disposable Observer
        onSuccess - the callback for upstream items
        Returns:
        the Disposable that allows disposing the particular subscription.

      • subscribeAutoDispose

        public static <T> Disposable subscribeAutoDispose​(Single<T> source,
                                                  CompositeDisposable composite,
                                                  Consumer<? super T> onSuccess,
                                                  Consumer<? super java.lang.Throwable> onError)
        Wraps the given onXXX callbacks into a Disposable Observer, adds it to the given CompositeDisposable and ensures, that if the upstream completes or this particlular Disposable is disposed, the Observer is removed from the given composite.

        The Observer will be removed after the callback for the terminal event has been invoked.

        Type Parameters:
        T - the value type
        Parameters:
        source - the source SingleObserver to subscribe to.
        composite - the composite Disposable to add and remove the created Disposable Observer
        onSuccess - the callback for upstream items
        onError - the callback for an upstream error if any
        Returns:
        the Disposable that allows disposing the particular subscription.