{"action":"created","issue":{"url":"https://api.github.com/repos/reactor/reactor/issues/381","labels_url":"https://api.github.com/repos/reactor/reactor/issues/381/labels{/name}","comments_url":"https://api.github.com/repos/reactor/reactor/issues/381/comments","events_url":"https://api.github.com/repos/reactor/reactor/issues/381/events","html_url":"https://github.com/reactor/reactor/issues/381","id":43199985,"number":381,"title":"Add selector (dynamic stream behavior) to various operations","user":{"login":"smaldini","id":76718,"avatar_url":"https://avatars.githubusercontent.com/u/76718?v=3","gravatar_id":"","url":"https://api.github.com/users/smaldini","html_url":"https://github.com/smaldini","followers_url":"https://api.github.com/users/smaldini/followers","following_url":"https://api.github.com/users/smaldini/following{/other_user}","gists_url":"https://api.github.com/users/smaldini/gists{/gist_id}","starred_url":"https://api.github.com/users/smaldini/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/smaldini/subscriptions","organizations_url":"https://api.github.com/users/smaldini/orgs","repos_url":"https://api.github.com/users/smaldini/repos","events_url":"https://api.github.com/users/smaldini/events{/privacy}","received_events_url":"https://api.github.com/users/smaldini/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2014-09-19T03:02:57Z","updated_at":"2015-05-22T13:27:29Z","closed_at":"2015-05-22T13:27:29Z","body":"A good number of actions (buffer, timeout, retry, window, groupBy...) could benefit from a feedback loop passed as an argument to either open or close a capturing action.\r\nE.g. \r\n```java\r\nStream<Control> controlStream = Streams.defer(env)\r\nstream.buffer(100,  controlStream).consume(...)\r\n//...\r\nstream.broadcastNext(1) //will be dropped by buffer operation\r\ncontrolStream.broadcastNext(Control.open()) //will start collecting\r\nstream.broadcastNext(2) //will be collected by buffer operation\r\ncontrolStream.broadcastNext(Control.close()) //will stop collecting\r\nstream.broadcastNext(3) //will be dropped by buffer operation\r\n```"},"comment":{"url":"https://api.github.com/repos/reactor/reactor/issues/comments/104660590","html_url":"https://github.com/reactor/reactor/issues/381#issuecomment-104660590","issue_url":"https://api.github.com/repos/reactor/reactor/issues/381","id":104660590,"user":{"login":"smaldini","id":76718,"avatar_url":"https://avatars.githubusercontent.com/u/76718?v=3","gravatar_id":"","url":"https://api.github.com/users/smaldini","html_url":"https://github.com/smaldini","followers_url":"https://api.github.com/users/smaldini/followers","following_url":"https://api.github.com/users/smaldini/following{/other_user}","gists_url":"https://api.github.com/users/smaldini/gists{/gist_id}","starred_url":"https://api.github.com/users/smaldini/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/smaldini/subscriptions","organizations_url":"https://api.github.com/users/smaldini/orgs","repos_url":"https://api.github.com/users/smaldini/repos","events_url":"https://api.github.com/users/smaldini/events{/privacy}","received_events_url":"https://api.github.com/users/smaldini/received_events","type":"User","site_admin":false},"created_at":"2015-05-22T13:27:29Z","updated_at":"2015-05-22T13:27:29Z","body":"Won't fix"}}