1 package au.gov.amsa.streams;
2
3 import rx.Observable;
4
5 public class Ob {
6
7 // TODO move this class to rxjava-extras
8
9 public static <T> Observable<T> justOne(T t) {
10 return Observable.unsafeCreate(new OnSubscribeJustOneWithBackpressure<T>(t));
11 }
12
13 }