{"action":"closed","issue":{"url":"https://api.github.com/repos/davidmoten/rxjava-file/issues/6","labels_url":"https://api.github.com/repos/davidmoten/rxjava-file/issues/6/labels{/name}","comments_url":"https://api.github.com/repos/davidmoten/rxjava-file/issues/6/comments","events_url":"https://api.github.com/repos/davidmoten/rxjava-file/issues/6/events","html_url":"https://github.com/davidmoten/rxjava-file/issues/6","id":103267223,"number":6,"title":"Interaction with standard operators","user":{"login":"mredaelli","id":3073833,"avatar_url":"https://avatars.githubusercontent.com/u/3073833?v=3","gravatar_id":"","url":"https://api.github.com/users/mredaelli","html_url":"https://github.com/mredaelli","followers_url":"https://api.github.com/users/mredaelli/followers","following_url":"https://api.github.com/users/mredaelli/following{/other_user}","gists_url":"https://api.github.com/users/mredaelli/gists{/gist_id}","starred_url":"https://api.github.com/users/mredaelli/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mredaelli/subscriptions","organizations_url":"https://api.github.com/users/mredaelli/orgs","repos_url":"https://api.github.com/users/mredaelli/repos","events_url":"https://api.github.com/users/mredaelli/events{/privacy}","received_events_url":"https://api.github.com/users/mredaelli/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":5,"created_at":"2015-08-26T13:16:08Z","updated_at":"2015-10-06T06:47:48Z","closed_at":"2015-10-06T06:47:48Z","body":"I have the following setup:\r\n\r\n        File file = new File(\".\\\\server.log\");\r\n        Observable<String> newLines =\r\n                FileObservable.tailer()\r\n                        .file(file)\r\n                        .startPosition(file.length())\r\n                        .sampleTimeMs(1000)\r\n                        .chunkSize(8192)\r\n                        .utf8()\r\n                        .tailText();\r\n\r\n        newLines.subscribe(System.out::println);\r\n\r\nand it works as expected.\r\nBut as soon as I try to chain some more operators, I get problems. For instance, changing to\r\n\r\n      newLines.filter(LogfileWatcher::error).subscribe(System.out::println);\r\n\r\n(where `error()` is a simple function `String -> Boolean`) I get output only after the first append to the file, but not the subsequent ones.\r\nSimilar problems appear when using `window()` or several other operators. For instance, using the `byLine()` function as suggested in the docs results in no output at all:\r\n\r\n        Observable<String> newLines1 = StringObservable.split(newLines, \"\\n\");\r\n        newLines1.subscribe(System.out::println);\r\n\r\nI'm very new to RX, so I don't know if I'm doing something wrong, though..."}}