hu.akarnokd.reactive4java.reactive

Class Resume.RetryCount<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Resume.RetryCount<T>

Type Parameters:

T - the type of elements

All Implemented Interfaces:

Observable<T>

Enclosing class:

Resume

public static final class Resume.RetryCount<T>
extends java.lang.Object
implements Observable<T>

Restarts the observation until the source observable terminates normally or the count retry count was used up.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	count
protected Observable<? extends T>	source

Constructor Summary

Constructors

Constructor and Description
RetryCount(Observable<? extends T> source, int count) 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<? extends T> source

count

protected final int count

Constructor Detail

RetryCount

public RetryCount(Observable<? extends T> source,
                  int count)

Constructor.

Parameters:

source - the source sequence

count - the number of retries

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