Make byLine handle carriage return, carriage return newline, and newline equally.

Author: abersnaze

src/main/java/rx/observables/StringObservable.java

@@ -551,15 +551,23 @@ public void onNext(String t) {
     }
 
     /**
-     * Splits the {@link Observable} of Strings by lines and numbers them (zero based index)
+     * Splits the {@link Observable} of Strings by line ending characters in a platform independent way. It is equivalent to
+     * <pre>split(src, "(\r\n)|(\n)|(\r)")</pre>
      * <p>
      * <img width="640" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/St.byLine.png" alt="">
      * 
      * @param source
      * @return the Observable conaining the split lines of the source
+     * @see StringObservable#split(Observable, Pattern)
      */
     public static Observable<String> byLine(Observable<String> source) {
-        return split(source, System.getProperty("line.separator"));
+        return split(source, ByLinePatternHolder.BY_LINE);
+    }
+    /**
+     * Lazy initialization of the pattern.
+     */
+    private static final class ByLinePatternHolder {
+        private static final Pattern BY_LINE = Pattern.compile("(\r\n)|(\n)|(\r)");
     }
 
     /**

src/test/java/rx/observables/StringObservableTest.java

@@ -356,8 +356,30 @@ public synchronized int read(byte[] b, int off, int len) {
     }
 
     @Test
-    public void testByLine() {
-        String newLine = System.getProperty("line.separator");
+    public void testByLine_Newline() {
+        String newLine = String.valueOf(new char[] { 10 });
+
+        List<String> lines = byLine(
+                Observable.from(Arrays.asList("qwer", newLine + "asdf" + newLine, "zx", "cv")))
+                .toList().toBlocking().single();
+
+        assertEquals(Arrays.asList("qwer", "asdf", "zxcv"), lines);
+    }
+
+    @Test
+    public void testByLine_CarriageNewline() {
+        String newLine = String.valueOf(new char[] { 13, 10 });
+
+        List<String> lines = byLine(
+                Observable.from(Arrays.asList("qwer", newLine + "asdf" + newLine, "zx", "cv")))
+                .toList().toBlocking().single();
+
+        assertEquals(Arrays.asList("qwer", "asdf", "zxcv"), lines);
+    }
+
+    @Test
+    public void testByLine_Carriage() {
+        String newLine = String.valueOf(new char[] { 13 });
 
         List<String> lines = byLine(
                 Observable.from(Arrays.asList("qwer", newLine + "asdf" + newLine, "zx", "cv")))