hu.akarnokd.reactive4java.reactive

Class Select.CastToken<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Select.CastToken<T>

Type Parameters:

T - the type of the expected values

All Implemented Interfaces:

Observable<T>

Enclosing class:

Select

public static final class Select.CastToken<T>
extends java.lang.Object
implements Observable<T>

Casts the values of the source sequence into the given type via the type token. ClassCastExceptions are relayed through the error method and the stream is stopped.

Field Summary

Fields

Modifier and Type	Field and Description
protected Observable<?>	source
protected java.lang.Class<T>	token

Constructor Summary

Constructors

Constructor and Description
CastToken(Observable<?> source, java.lang.Class<T> token) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super T> 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

Field Detail

source

protected final Observable<?> source

token

protected final java.lang.Class<T> token

Constructor Detail

CastToken

public CastToken(Observable<?> source,
                 java.lang.Class<T> token)

Constructor.

Parameters:

source - the source of unknown elements

token - the token to test agains the elements

Method Detail

register

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

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider