Move ObservableSplit into internals

ReactiveX · Dec 12, 2016 · 47e0c48 · 47e0c48
1 parent 67de5c6
commit 47e0c48
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 27 deletions.
diff --git a/.../java/rx/observables/ObservableSplit.java → ...x/internal/operators/ObservableSplit.java b/.../java/rx/observables/ObservableSplit.java → ...x/internal/operators/ObservableSplit.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package rx.observables;
+package rx.internal.operators;
 
 import java.util.Queue;
 import java.util.concurrent.atomic.*;
@@ -32,15 +32,15 @@
  * Split a sequence of strings based on a Rexexp pattern spanning subsequent
  * items if necessary.
  */
-final class ObservableSplit implements OnSubscribe<String> {
+public final class ObservableSplit implements OnSubscribe<String> {
 
     final Observable<String> source;
 
     final Pattern pattern;
 
     final int bufferSize;
 
-    ObservableSplit(Observable<String> source, Pattern pattern, int bufferSize) {
+    public ObservableSplit(Observable<String> source, Pattern pattern, int bufferSize) {
         this.source = source;
         this.pattern = pattern;
         this.bufferSize = bufferSize;

diff --git a/src/main/java/rx/observables/StringObservable.java b/src/main/java/rx/observables/StringObservable.java
@@ -15,34 +15,19 @@
  */
 package rx.observables;
 
-import rx.Observable;
-import rx.Observable.Operator;
-import rx.Producer;
-import rx.Subscriber;
-import rx.functions.Action1;
-import rx.functions.Func0;
-import rx.functions.Func1;
-import rx.functions.Func2;
-import rx.internal.operators.OnSubscribeInputStream;
-import rx.internal.operators.OnSubscribeReader;
-import rx.internal.util.RxRingBuffer;
-
-import java.io.Closeable;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.Reader;
-import java.nio.ByteBuffer;
-import java.nio.CharBuffer;
-import java.nio.charset.CharacterCodingException;
-import java.nio.charset.Charset;
-import java.nio.charset.CharsetDecoder;
-import java.nio.charset.CharsetEncoder;
-import java.nio.charset.CoderResult;
-import java.nio.charset.CodingErrorAction;
+import java.io.*;
+import java.nio.*;
+import java.nio.charset.*;
 import java.util.Arrays;
 import java.util.concurrent.Callable;
 import java.util.regex.Pattern;
 
+import rx.*;
+import rx.Observable.Operator;
+import rx.functions.*;
+import rx.internal.operators.*;
+import rx.internal.util.RxRingBuffer;
+
 public class StringObservable {
     /**
      * Reads bytes from a source {@link InputStream} and outputs {@link Observable} of