StringObservable { public static Observable<byte[]> encode(Observable<String> src, String charsetName) { return encode(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);  }
@Test public void testEncode() { assertArrayEquals( new byte[] { (byte) 0xc2, (byte) 0xa1 }, StringObservable.encode(Observable.just("\u00A1"), "UTF-8").toBlockingObservable().single()); }