java-8 - RxJava 文件和运算符链接

Question

我正在尝试使用 RxJava-File 被动地跟踪日志文件:

    File file = new File(".\\server.log");
    Observable<String> newLines =
            FileObservable.tailer()
                    .file(file)
                    .startPosition(file.length())
                    .sampleTimeMs(1000)
                    .chunkSize(8192)
                    .utf8()
                    .tailText();

    newLines.subscribe(System.out::println);

它按预期工作。
但是一旦我尝试链接更多操作符，我就会遇到问题。例如，更改为

  newLines.filter(LogfileWatcher::error).subscribe(System.out::println);

(其中 error() 是一个简单的函数 String -> Boolean )我只在第一次追加到文件后得到输出，而不是后续的。
使用 window()时出现类似问题或其他几个运营商。

我究竟做错了什么？

Answer 1

必须在 rxjava-file 中修复背压支持，并且据报告您的测试用例从 Maven Central 上的 rxjava-file 0.3.3 开始工作。