@Test
public void testMalformedInTheMiddleReplace() {

    Observable<byte[]> src = Observable.from(new byte[] { (byte) 0xc2, 65 });
    String out = StringObservable.decode(src, "UTF-8").toBlockingObservable().single();
    // REPLACEMENT CHARACTER
    assertEquals("\uFFFDA", out);
}