hu.akarnokd.reactive4java.reactive

Class Repeat.RepeatValue<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Repeat.RepeatValue<T>

Type Parameters:

T - the type of elements to produce

All Implemented Interfaces:

Observable<T>

Enclosing class:

Repeat

public static class Repeat.RepeatValue<T>
extends java.lang.Object
implements Observable<T>

Creates an observable which repeatedly calls the given function which generates the Ts indefinitely. The generator runs on the pool. Note that observers must unregister to stop the infinite loop.

Field Summary

Fields

Modifier and Type	Field and Description
protected Func0<? extends T>	func The function which generates elements.
protected Scheduler	pool The pool where the generator loop runs.

Constructor Summary

Constructors

Constructor and Description
RepeatValue(Func0<? extends T> func, Scheduler pool) 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

pool

protected final Scheduler pool

The pool where the generator loop runs.

func

protected final Func0<? extends T> func

The function which generates elements.

Constructor Detail

RepeatValue

public RepeatValue(Func0<? extends T> func,
                   Scheduler pool)

Constructor.

Parameters:

func - the function which generates elements

pool - the pool where the generator loop runs

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