如何将 Observable<byte[]> 转换为 Observable<String>？
How to convert Observable<byte[]> to Observable<String>?
我正在使用 process.getInputStream() 读取进程的标准输出。我想创建一个可以输出字符串的可观察对象。
有了 StringObservable.from(process.getInputStream())，我得到了 Observable<byte[]>。如何在运行中将其翻译成部分字符串？
我找到了 https://github.com/ReactiveX/RxJava/wiki/String-Observables#decode 但不知道如何使用它。文本以 UTF-8 编码。
可以使用public static Observable<String> decode(Observable<byte[]> src, String charsetName)，比如StringStringObservable.decode(StringObservable.from(process.getInputStream()), "UTF-8")
我正在使用 process.getInputStream() 读取进程的标准输出。我想创建一个可以输出字符串的可观察对象。
有了 StringObservable.from(process.getInputStream())，我得到了 Observable<byte[]>。如何在运行中将其翻译成部分字符串？
我找到了 https://github.com/ReactiveX/RxJava/wiki/String-Observables#decode 但不知道如何使用它。文本以 UTF-8 编码。
可以使用public static Observable<String> decode(Observable<byte[]> src, String charsetName)，比如StringStringObservable.decode(StringObservable.from(process.getInputStream()), "UTF-8")