{"action":"created","issue":{"url":"https://api.github.com/repos/akka/akka/issues/24642","repository_url":"https://api.github.com/repos/akka/akka","labels_url":"https://api.github.com/repos/akka/akka/issues/24642/labels{/name}","comments_url":"https://api.github.com/repos/akka/akka/issues/24642/comments","events_url":"https://api.github.com/repos/akka/akka/issues/24642/events","html_url":"https://github.com/akka/akka/pull/24642","id":301598402,"number":24642,"title":"Do not drop messages when delaying with EmitEarly strategy and the buffer overflows","user":{"login":"kmruiz","id":1822138,"avatar_url":"https://avatars3.githubusercontent.com/u/1822138?v=4","gravatar_id":"","url":"https://api.github.com/users/kmruiz","html_url":"https://github.com/kmruiz","followers_url":"https://api.github.com/users/kmruiz/followers","following_url":"https://api.github.com/users/kmruiz/following{/other_user}","gists_url":"https://api.github.com/users/kmruiz/gists{/gist_id}","starred_url":"https://api.github.com/users/kmruiz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kmruiz/subscriptions","organizations_url":"https://api.github.com/users/kmruiz/orgs","repos_url":"https://api.github.com/users/kmruiz/repos","events_url":"https://api.github.com/users/kmruiz/events{/privacy}","received_events_url":"https://api.github.com/users/kmruiz/received_events","type":"User","site_admin":false},"labels":[{"id":37797347,"url":"https://api.github.com/repos/akka/akka/labels/tested","name":"tested","color":"d7e102","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2018-03-01T23:26:23Z","updated_at":"2018-03-02T02:22:46Z","closed_at":null,"author_association":"NONE","pull_request":{"url":"https://api.github.com/repos/akka/akka/pulls/24642","html_url":"https://github.com/akka/akka/pull/24642","diff_url":"https://github.com/akka/akka/pull/24642.diff","patch_url":"https://github.com/akka/akka/pull/24642.patch"},"body":"Resolves: #24633 \r\n\r\nI simplified the test, because it can be reproduceable with only two messages and a buffer of initSize 1 and maxSize 1.\r\n\r\nWhat I've found is that, in case of overflow, we were pushing the next message downstream but not pulling the message that actually caused the overflow, so we were dropping alternate messages after the first overflow occurs.\r\n\r\nThat explains the weird behavior we found in the issue, of dropping messages 17 and 19, when the buffer was 16,16.\r\n\r\nHope it helps!"},"comment":{"url":"https://api.github.com/repos/akka/akka/issues/comments/369799052","html_url":"https://github.com/akka/akka/pull/24642#issuecomment-369799052","issue_url":"https://api.github.com/repos/akka/akka/issues/24642","id":369799052,"user":{"login":"akka-ci","id":2511948,"avatar_url":"https://avatars3.githubusercontent.com/u/2511948?v=4","gravatar_id":"","url":"https://api.github.com/users/akka-ci","html_url":"https://github.com/akka-ci","followers_url":"https://api.github.com/users/akka-ci/followers","following_url":"https://api.github.com/users/akka-ci/following{/other_user}","gists_url":"https://api.github.com/users/akka-ci/gists{/gist_id}","starred_url":"https://api.github.com/users/akka-ci/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/akka-ci/subscriptions","organizations_url":"https://api.github.com/users/akka-ci/orgs","repos_url":"https://api.github.com/users/akka-ci/repos","events_url":"https://api.github.com/users/akka-ci/events{/privacy}","received_events_url":"https://api.github.com/users/akka-ci/received_events","type":"User","site_admin":false},"created_at":"2018-03-02T02:22:46Z","updated_at":"2018-03-02T02:22:46Z","author_association":"COLLABORATOR","body":"Test PASSed.\n"}}
{"actor":{"display_login":"akka-ci"}}