我对 RxJava 和响应式编程完全陌生。我有一个任务,我必须读取文件并将其存储到 Observable。我曾尝试在内部使用 BufferedReader 制作 Callable 并使用 Observable.fromCallable(),但效果不佳。
你能告诉我我该怎么做吗?
我正在使用 RxJava 2.0。
java reactive-programming java-8 rx-java rx-java2
java ×1
java-8 ×1
reactive-programming ×1
rx-java ×1
rx-java2 ×1