public class TaskedObservable<T,TConnectionState extends IChangesConnectionState> extends Object implements IObservable<T>
Modifier and Type | Field and Description |
---|---|
protected Predicate<T> |
filter |
protected TConnectionState |
localConnectionState |
protected ConcurrentSet<IObserver<T>> |
subscribers |
Constructor and Description |
---|
TaskedObservable(TConnectionState localConnectionState,
Predicate<T> filter) |
protected final TConnectionState extends IChangesConnectionState localConnectionState
protected ConcurrentSet<IObserver<T>> subscribers
public TaskedObservable(TConnectionState localConnectionState, Predicate<T> filter)
public CleanCloseable subscribe(IObserver<T> observer)
subscribe
in interface IObservable<T>
public void send(T msg)
public void error(Exception obj)
public IObservable<T> where(Predicate<T> predicate)
where
in interface IObservable<T>
Copyright © 2016. All Rights Reserved.