{"action":"created","issue":{"url":"https://api.github.com/repos/sksamuel/elastic4s/issues/447","labels_url":"https://api.github.com/repos/sksamuel/elastic4s/issues/447/labels{/name}","comments_url":"https://api.github.com/repos/sksamuel/elastic4s/issues/447/comments","events_url":"https://api.github.com/repos/sksamuel/elastic4s/issues/447/events","html_url":"https://github.com/sksamuel/elastic4s/issues/447","id":107766109,"number":447,"title":"Support non-ES processing of streaming events","user":{"login":"nilsga","id":42919,"avatar_url":"https://avatars.githubusercontent.com/u/42919?v=3","gravatar_id":"","url":"https://api.github.com/users/nilsga","html_url":"https://github.com/nilsga","followers_url":"https://api.github.com/users/nilsga/followers","following_url":"https://api.github.com/users/nilsga/following{/other_user}","gists_url":"https://api.github.com/users/nilsga/gists{/gist_id}","starred_url":"https://api.github.com/users/nilsga/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/nilsga/subscriptions","organizations_url":"https://api.github.com/users/nilsga/orgs","repos_url":"https://api.github.com/users/nilsga/repos","events_url":"https://api.github.com/users/nilsga/events{/privacy}","received_events_url":"https://api.github.com/users/nilsga/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/sksamuel/elastic4s/labels/question","name":"question","color":"cc317c"}],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":6,"created_at":"2015-09-22T17:52:41Z","updated_at":"2015-11-18T21:38:30Z","closed_at":"2015-11-18T21:38:30Z","body":"I'm looking into the `ReactiveElastic` publish/subscribe mechanism, and I have succesfully implemented it in a \"query then delete\" scenario. However, I now have a use case which involves only streaming and then collecting responses. That is, I don't really want a `RequestBuilder` with an index/delete-operation. I just want to receive a hit, and then transform it to an instance of some other type. More or less a `map` operation over the hits in the stream. Is that possible?"},"comment":{"url":"https://api.github.com/repos/sksamuel/elastic4s/issues/comments/157873112","html_url":"https://github.com/sksamuel/elastic4s/issues/447#issuecomment-157873112","issue_url":"https://api.github.com/repos/sksamuel/elastic4s/issues/447","id":157873112,"user":{"login":"sksamuel","id":743706,"avatar_url":"https://avatars.githubusercontent.com/u/743706?v=3","gravatar_id":"","url":"https://api.github.com/users/sksamuel","html_url":"https://github.com/sksamuel","followers_url":"https://api.github.com/users/sksamuel/followers","following_url":"https://api.github.com/users/sksamuel/following{/other_user}","gists_url":"https://api.github.com/users/sksamuel/gists{/gist_id}","starred_url":"https://api.github.com/users/sksamuel/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sksamuel/subscriptions","organizations_url":"https://api.github.com/users/sksamuel/orgs","repos_url":"https://api.github.com/users/sksamuel/repos","events_url":"https://api.github.com/users/sksamuel/events{/privacy}","received_events_url":"https://api.github.com/users/sksamuel/received_events","type":"User","site_admin":false},"created_at":"2015-11-18T21:38:30Z","updated_at":"2015-11-18T21:38:30Z","body":"Closing this. Please re-open if there's functionality you'd like to see added."}}