@Test(expected = RuntimeException.class) public void testMalformedInTheMiddleReport() { Observable<byte[]> src = Observable.from(new byte[] { (byte) 0xc2, 65 }); CharsetDecoder charsetDecoder = Charset.forName("UTF-8").newDecoder(); StringObservable.decode(src, charsetDecoder).toBlockingObservable().single(); }
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);  }