package au.gov.amsa.streams;

import rx.Observable;

public class Ob {

	// TODO move this class to rxjava-extras

	public static <T> Observable<T> justOne(T t) {
		return Observable.create(new OnSubscribeJustOneWithBackpressure<T>(t));
	}

}

@@ -176,17 +176,23 @@
 ervable.
-c
+unsafeC
 reate(ne

use Observable.unsafeCreate instead of deprecated Observable.create