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