File tree Expand file tree Collapse file tree 1 file changed +12
-4
lines changed
rxjava-core/src/main/java/rx/observables Expand file tree Collapse file tree 1 file changed +12
-4
lines changed Original file line number Diff line number Diff line change 44
44
*/
45
45
public class BlockingObservable <T > extends Observable <T > {
46
46
47
+ protected BlockingObservable (Func1 <Observer <T >, Subscription > onSubscribe ) {
48
+ super (onSubscribe );
49
+ }
50
+
51
+ /**
52
+ * Used to prevent public instantiation
53
+ */
54
+ @ SuppressWarnings ("unused" )
55
+ private BlockingObservable () {
56
+ // prevent public instantiation
57
+ }
58
+
47
59
public static <T > BlockingObservable <T > from (final Observable <T > o ) {
48
60
return new BlockingObservable <T >(new Func1 <Observer <T >, Subscription >() {
49
61
@@ -330,10 +342,6 @@ public static <T> Iterable<T> toIterable(final Observable<T> source) {
330
342
return from (source ).toIterable ();
331
343
}
332
344
333
- protected BlockingObservable (Func1 <Observer <T >, Subscription > onSubscribe ) {
334
- super (onSubscribe );
335
- }
336
-
337
345
/**
338
346
* Used for protecting against errors being thrown from Observer implementations and ensuring onNext/onError/onCompleted contract compliance.
339
347
* <p>
You can’t perform that action at this time.
0 commit comments