public class ShardedObservable<T> extends Object implements IObservable<T>
Constructor and Description |
---|
ShardedObservable(List<IObservable<T>> inner) |
public ShardedObservable(List<IObservable<T>> inner)
public CleanCloseable subscribe(IObserver<T> observer)
subscribe
in interface IObservable<T>
public IObservable<T> where(Predicate<T> predicate)
where
in interface IObservable<T>
Copyright © 2016. All Rights Reserved.