com.yahoo.bard.webservice.util

Class CacheLastObserver<T>

java.lang.Object

com.yahoo.bard.webservice.util.CacheLastObserver<T>

Type Parameters:

T - The type of message this Observer caches

All Implemented Interfaces:

rx.Observer<T>

public class CacheLastObserver<T>
extends Object
implements rx.Observer<T>

A thread-safe observable that caches the last message it received, and caches the last error (if any) it receives.

Constructor Summary

Constructors

Constructor and Description
CacheLastObserver()

Method Summary

Modifier and Type	Method and Description
Optional<Throwable>	getError() Returns the last error received by this Observable, if any.
Optional<T>	getLastMessageReceived() The last message received by this Observable, if any.
void	onCompleted()
void	onError(Throwable e)
void	onNext(T message)

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheLastObserver

public CacheLastObserver()

Method Detail

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface rx.Observer<T>

onError

public void onError(Throwable e)

Specified by:

onError in interface rx.Observer<T>

onNext

public void onNext(T message)

Specified by:

onNext in interface rx.Observer<T>

getLastMessageReceived

public Optional<T> getLastMessageReceived()

The last message received by this Observable, if any.

Returns:

the last message received by this Observable, if any

getError

public Optional<Throwable> getError()

Returns the last error received by this Observable, if any.

Returns:

The last error received by this Observable, if any