Package hu.akarnokd.rxjava3.joins

Class Plan<R>

java.lang.Object

hu.akarnokd.rxjava3.joins.Plan<R>

Type Parameters:

R - the result type

public abstract class Plan<R>
extends Object

Represents an execution plan for join patterns.

Constructor Summary

Constructors

Constructor	Description
Plan()

Method Summary

Modifier and Type	Method	Description
protected static <T> Consumer<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<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.