hu.akarnokd.reactive4java.reactive

Class CombineLatest.NullStart<T,U,V>

java.lang.Object

hu.akarnokd.reactive4java.reactive.CombineLatest.NullStart<T,U,V>

Type Parameters:

T - the left element type

U - the right element type

V - the result element type

All Implemented Interfaces:

Observable<V>

Enclosing class:

CombineLatest

public static final class CombineLatest.NullStart<T,U,V>
extends java.lang.Object
implements Observable<V>

Returns an observable which combines the latest values of both streams whenever one sends a new value, but only after both sent a value.

Exception semantics: if any stream throws an exception, the output stream throws an exception and all registrations are terminated.

Completion semantics: The output stream terminates after both streams terminate.

Note that at the beginning, when the left or right fires first, the selector function will receive (value, null) or (null, value). If you want to react only in cases when both have sent a value, use the CombineLatest.Sent class and combineLatest operator.

Constructor Summary

Constructors

Constructor and Description
NullStart(Observable<? extends T> left, Observable<? extends U> right, Func2<? super T,? super U,? extends V> selector) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super V> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

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

Constructor Detail

NullStart

public NullStart(Observable<? extends T> left,
                 Observable<? extends U> right,
                 Func2<? super T,? super U,? extends V> selector)

Constructor.

Parameters:

left - the left stream

right - the right stream

selector - the function which combines values from both streams and returns a new value

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super V> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<V>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider