Forgot to commit the new wrappers that bridge the old and the new

Author: akarnokd

src/main/java/io/reactivex/internal/operators/completable/CompletableWrapper.java

@@ -0,0 +1,17 @@
+package io.reactivex.internal.operators.completable;
+
+import io.reactivex.Completable;
+
+public final class CompletableWrapper extends Completable {
+
+    final CompletableOnSubscribe onSubscribe;
+
+    public CompletableWrapper(CompletableOnSubscribe onSubscribe) {
+        this.onSubscribe = onSubscribe;
+    }
+    
+    @Override
+    protected void subscribeActual(CompletableSubscriber s) {
+        onSubscribe.accept(s);
+    }
+}

src/main/java/io/reactivex/internal/operators/flowable/FlowableWrapper.java

@@ -0,0 +1,18 @@
+package io.reactivex.internal.operators.flowable;
+
+import org.reactivestreams.*;
+
+import io.reactivex.Flowable;
+
+public final class FlowableWrapper<T> extends Flowable<T> {
+    final Publisher<? extends T> publisher;
+
+    public FlowableWrapper(Publisher<? extends T> publisher) {
+        this.publisher = publisher;
+    }
+    
+    @Override
+    protected void subscribeActual(Subscriber<? super T> s) {
+        publisher.subscribe(s);
+    }
+}

src/main/java/io/reactivex/internal/operators/observable/ObservableWrapper.java

@@ -0,0 +1,16 @@
+package io.reactivex.internal.operators.observable;
+
+import io.reactivex.*;
+
+public final class ObservableWrapper<T> extends Observable<T> {
+    final NbpOnSubscribe<T> onSubscribe;
+
+    public ObservableWrapper(NbpOnSubscribe<T> onSubscribe) {
+        this.onSubscribe = onSubscribe;
+    }
+    
+    @Override
+    protected void subscribeActual(Observer<? super T> observer) {
+        onSubscribe.accept(observer);
+    }
+}

src/main/java/io/reactivex/internal/operators/single/SingleWrapper.java

@@ -0,0 +1,16 @@
+package io.reactivex.internal.operators.single;
+
+import io.reactivex.Single;
+
+public final class SingleWrapper<T> extends Single<T> {
+    final SingleOnSubscribe<T> onSubscribe;
+
+    public SingleWrapper(io.reactivex.Single.SingleOnSubscribe<T> onSubscribe) {
+        this.onSubscribe = onSubscribe;
+    }
+    
+    @Override
+    protected void subscribeActual(io.reactivex.Single.SingleSubscriber<? super T> subscriber) {
+        onSubscribe.accept(subscriber);
+    }
+}