hu.akarnokd.rxjava3.joins

Class PatternN

java.lang.Object

hu.akarnokd.rxjava3.joins.PatternN

public final class PatternN
extends Object

Represents a join pattern over observable sequences.

Constructor Summary

Constructors

Constructor and Description
PatternN(List<Observable<? extends Object>> observables)
PatternN(List<Observable<? extends Object>> observables, Observable<? extends Object> other)

Method Summary

Modifier and Type	Method and Description
PatternN	and(Observable<? extends Object> other) Creates a pattern that matches when all previous observable sequences have an available element.
<R> Plan<R>	then(Function<? super Object[],R> selector) Matches when all observable sequences have an available element and projects the elements by invoking the selector function.

Methods inherited from class java.lang.Object

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

Constructor Detail

PatternN

public PatternN(List<Observable<? extends Object>> observables)

PatternN

public PatternN(List<Observable<? extends Object>> observables,
                Observable<? extends Object> other)

Method Detail

and

public PatternN and(Observable<? extends Object> other)

Creates a pattern that matches when all previous observable sequences have an available element.

Parameters:

other - Observable sequence to match with the previous sequences.

Returns:

Pattern object that matches when all observable sequences have an available element.

then

public <R> Plan<R> then(Function<? super Object[],R> selector)

Matches when all observable sequences have an available element and projects the elements by invoking the selector function.

Type Parameters:

R - the result type

Parameters:

selector - the function that will be invoked for elements in the source sequences.

Returns:

the plan for the matching

Throws:

NullPointerException - if selector is null