RxJava文件和运营商链接

我试图被动尾部使用RxJava-File日志文件：RxJava文件和运营商链接

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()或其他几个操作符时会出现类似的问题。

我在做什么错？

来源

2015-09-18 kenshin

有意思，我来看看。 rxjava-file是我的一个早期创建者，可能是时候回顾一下了。 –

背压支持，不得不固定在rxjava文件和测试用例据报道工作，当rxjava文件 0.3.3 Maven的中央。

来源

2015-10-15 06:20:24

RxJava文件和运营商链接

回答

相关问题