{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4162","repository_url":"https://api.github.com/repos/ReactiveX/RxJava","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4162/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4162/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4162/events","html_url":"https://github.com/ReactiveX/RxJava/issues/4162","id":163753440,"number":4162,"title":"1.x: OnSubscribeConcatMap regression IllegalStateException: More items arrived than were requested","user":{"login":"nikitin-da","id":7294857,"avatar_url":"https://avatars.githubusercontent.com/u/7294857?v=3","gravatar_id":"","url":"https://api.github.com/users/nikitin-da","html_url":"https://github.com/nikitin-da","followers_url":"https://api.github.com/users/nikitin-da/followers","following_url":"https://api.github.com/users/nikitin-da/following{/other_user}","gists_url":"https://api.github.com/users/nikitin-da/gists{/gist_id}","starred_url":"https://api.github.com/users/nikitin-da/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/nikitin-da/subscriptions","organizations_url":"https://api.github.com/users/nikitin-da/orgs","repos_url":"https://api.github.com/users/nikitin-da/repos","events_url":"https://api.github.com/users/nikitin-da/events{/privacy}","received_events_url":"https://api.github.com/users/nikitin-da/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/ReactiveX/RxJava/labels/Question","name":"Question","color":"cc317c"}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":7,"created_at":"2016-07-05T00:18:49Z","updated_at":"2016-07-06T09:02:09Z","closed_at":"2016-07-05T08:11:05Z","body":"Hi!\r\nStarting from 1.1.2 and above test failed =(\r\n```java\r\n@Test\r\npublic void producerArbiterWithFewOnSubscribe() throws InterruptedException {\r\n    TestSubscriber<Object> testSubscriber = TestSubscriber.create();\r\n\r\n    Observable.just(new Object())\r\n            .startWith(Observable.create(subscriber -> {\r\n                if (!subscriber.isUnsubscribed()) {\r\n                    subscriber.onNext(new Object());\r\n                    subscriber.onCompleted();\r\n                }\r\n            }))\r\n            .subscribeOn(Schedulers.io())\r\n            .subscribeOn(Schedulers.io())   // twice\r\n            .subscribe(testSubscriber);\r\n\r\n    testSubscriber.awaitTerminalEvent();\r\n    testSubscriber.assertNoErrors();\r\n}\r\n```"},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/230717381","html_url":"https://github.com/ReactiveX/RxJava/issues/4162#issuecomment-230717381","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4162","id":230717381,"user":{"login":"artem-zinnatullin","id":967132,"avatar_url":"https://avatars.githubusercontent.com/u/967132?v=3","gravatar_id":"","url":"https://api.github.com/users/artem-zinnatullin","html_url":"https://github.com/artem-zinnatullin","followers_url":"https://api.github.com/users/artem-zinnatullin/followers","following_url":"https://api.github.com/users/artem-zinnatullin/following{/other_user}","gists_url":"https://api.github.com/users/artem-zinnatullin/gists{/gist_id}","starred_url":"https://api.github.com/users/artem-zinnatullin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/artem-zinnatullin/subscriptions","organizations_url":"https://api.github.com/users/artem-zinnatullin/orgs","repos_url":"https://api.github.com/users/artem-zinnatullin/repos","events_url":"https://api.github.com/users/artem-zinnatullin/events{/privacy}","received_events_url":"https://api.github.com/users/artem-zinnatullin/received_events","type":"User","site_admin":false},"created_at":"2016-07-06T09:02:09Z","updated_at":"2016-07-06T09:02:09Z","body":"Hm, well you're right, but changelog for 1.1.2 didn't mention that `Observable` passed to `concat`, `startWith` and `concatMap` now required to honor backpressure.\r\n\r\nMaybe worth to add that to changelog? Otherwise it is still a regression in my opinion because it breaks existing code (which isn't perfect, but worked with RxJava < 1.1.2)."}}
{"actor":{"display_login":"artem-zinnatullin"}}