@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();
}