{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/6233","repository_url":"https://api.github.com/repos/ReactiveX/RxJava","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/6233/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/6233/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/6233/events","html_url":"https://github.com/ReactiveX/RxJava/issues/6233","id":365247203,"node_id":"MDU6SXNzdWUzNjUyNDcyMDM=","number":6233,"title":"2.2.0 - Question - Flowable.GroupBy Memory Usage","user":{"login":"reformingpanda","id":9117170,"node_id":"MDQ6VXNlcjkxMTcxNzA=","avatar_url":"https://avatars2.githubusercontent.com/u/9117170?v=4","gravatar_id":"","url":"https://api.github.com/users/reformingpanda","html_url":"https://github.com/reformingpanda","followers_url":"https://api.github.com/users/reformingpanda/followers","following_url":"https://api.github.com/users/reformingpanda/following{/other_user}","gists_url":"https://api.github.com/users/reformingpanda/gists{/gist_id}","starred_url":"https://api.github.com/users/reformingpanda/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/reformingpanda/subscriptions","organizations_url":"https://api.github.com/users/reformingpanda/orgs","repos_url":"https://api.github.com/users/reformingpanda/repos","events_url":"https://api.github.com/users/reformingpanda/events{/privacy}","received_events_url":"https://api.github.com/users/reformingpanda/received_events","type":"User","site_admin":false},"labels":[{"id":480313802,"node_id":"MDU6TGFiZWw0ODAzMTM4MDI=","url":"https://api.github.com/repos/ReactiveX/RxJava/labels/2.x","name":"2.x","color":"af40af","default":false},{"id":24234455,"node_id":"MDU6TGFiZWwyNDIzNDQ1NQ==","url":"https://api.github.com/repos/ReactiveX/RxJava/labels/Question","name":"Question","color":"cc317c","default":false}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2018-09-30T18:12:41Z","updated_at":"2018-09-30T22:13:11Z","closed_at":"2018-09-30T22:13:11Z","author_association":"NONE","body":"I have some questions about the groupBy operator and its memory usage.\r\n\r\n1. Does Flowable.groupBy begin to emit GroupedFlowables as the groupBy keys are encountered or are they held back until the full set of groupBy keys can be identified?  How much buffering of source emissions does Flowable.groupBy do?  Or is it more like a situation where Flowable.groupBy publishes to the GroupedFlowable for a corresponding groupBy key as it's encountered?\r\n2. If I have a very long source Flowable (millions of emissions) which emits its items in sorted order of the value I want to use as a groupBy key, should I be concerned about memory issues (OutOfMemoryError, etc.) with using Flowable.groupBy()?"},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/425756321","html_url":"https://github.com/ReactiveX/RxJava/issues/6233#issuecomment-425756321","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/6233","id":425756321,"node_id":"MDEyOklzc3VlQ29tbWVudDQyNTc1NjMyMQ==","user":{"login":"reformingpanda","id":9117170,"node_id":"MDQ6VXNlcjkxMTcxNzA=","avatar_url":"https://avatars2.githubusercontent.com/u/9117170?v=4","gravatar_id":"","url":"https://api.github.com/users/reformingpanda","html_url":"https://github.com/reformingpanda","followers_url":"https://api.github.com/users/reformingpanda/followers","following_url":"https://api.github.com/users/reformingpanda/following{/other_user}","gists_url":"https://api.github.com/users/reformingpanda/gists{/gist_id}","starred_url":"https://api.github.com/users/reformingpanda/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/reformingpanda/subscriptions","organizations_url":"https://api.github.com/users/reformingpanda/orgs","repos_url":"https://api.github.com/users/reformingpanda/repos","events_url":"https://api.github.com/users/reformingpanda/events{/privacy}","received_events_url":"https://api.github.com/users/reformingpanda/received_events","type":"User","site_admin":false},"created_at":"2018-09-30T22:13:11Z","updated_at":"2018-09-30T22:13:11Z","author_association":"NONE","body":"Perfect, thank you."}}
{"actor":{"display_login":"reformingpanda"}}