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文件和運營商鏈接

回答

相關問題