public class TimeoutSubject<T> extends Object implements Subject<T,T>
Constructor and Description |
---|
TimeoutSubject(long timeout,
Observer<T> handler) |
Modifier and Type | Method and Description |
---|---|
void |
onCompleted()
Notifies the observer that the provider has finished sending push-based
notifications.
|
void |
onError(Exception error)
Notifies the observer that the provider has experienced an error
condition.
|
void |
onNext(T value)
Provides the observer with new data.
|
public TimeoutSubject(long timeout, Observer<T> handler)
public void onNext(T value)
Observer
public void onError(Exception error)
Observer
public void onCompleted()
Observer
onCompleted
in interface Observer<T>
Copyright © 2015 The Apache Software Foundation. All rights reserved.