@Test public void testMultibyteSpanningTwoBuffers() { Observable<byte[]> src = Observable.from(new byte[] { (byte) 0xc2 }, new byte[] { (byte) 0xa1 }); String out = StringObservable.decode(src, "UTF-8").toBlockingObservable().single(); assertEquals("\u00A1", out); }
public static Observable<String> decode(Observable<byte[]> src, String charsetName) { return decode(src, Charset.forName(charsetName)); }
StringObservable { public static Observable<String> decode(Observable<byte[]> src, String charsetName) { return decode(src, Charset.forName(charsetName)); } }
StringObservable { public static Observable<String> decode(Observable<byte[]> src, String charsetName) { return decode(src, Charset.forName(charsetName)); }  }
StringObservable { public static Observable<String> decode(Observable<byte[]> src, String charsetName) { return decode(src, Charset.forName(charsetName)); }  static Observable<String> decode(Observable<byte[]> src, String charsetName); static Observable<String> decode(Observable<byte[]> src, Charset charset); static Observable<String> decode(final Observable<byte[]> src, final CharsetDecoder charsetDecoder); static Observable<byte[]> encode(Observable<String> src, String charsetName); static Observable<byte[]> encode(Observable<String> src, Charset charset); static Observable<byte[]> encode(Observable<String> src, final CharsetEncoder charsetEncoder); static Observable<String> stringConcat(Observable<String> src); static Observable<String> split(final Observable<String> src, String regex); static Observable<String> join(final Observable<T> source, final CharSequence separator); }
StringObservable { public static Observable<String> decode(Observable<byte[]> src, String charsetName) { return decode(src, Charset.forName(charsetName)); }  static Observable<String> decode(Observable<byte[]> src, String charsetName); static Observable<String> decode(Observable<byte[]> src, Charset charset); static Observable<String> decode(final Observable<byte[]> src, final CharsetDecoder charsetDecoder); static Observable<byte[]> encode(Observable<String> src, String charsetName); static Observable<byte[]> encode(Observable<String> src, Charset charset); static Observable<byte[]> encode(Observable<String> src, final CharsetEncoder charsetEncoder); static Observable<String> stringConcat(Observable<String> src); static Observable<String> split(final Observable<String> src, String regex); static Observable<String> join(final Observable<T> source, final CharSequence separator);  }