Package hu.akarnokd.rxjava3.joins

Class Plan<R>

  • Type Parameters:
    R - the result type
    public abstract class Plan<R>
extends java.lang.Object
    Represents an execution plan for join patterns.

    • Constructor Summary

      Constructors 
      Constructor Description
      Plan()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      protected static <T> Consumer<java.lang.Throwable> onErrorFrom​(Observer<T> observer)
      Extracts a method reference to the Observer's onError method in the form of an Consumer.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Plan

        public Plan()

    • Method Detail

      • onErrorFrom

        protected static <T> Consumer<java.lang.Throwable> onErrorFrom​(Observer<T> observer)
        Extracts a method reference to the Observer's onError method in the form of an Consumer.

        Java 8: observer::onError

        Type Parameters:
        T - the value type
        Parameters:
        observer - the Observer to use
        Returns:
        an action which calls observer's onError method.