{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4821","repository_url":"https://api.github.com/repos/ReactiveX/RxJava","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4821/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4821/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4821/events","html_url":"https://github.com/ReactiveX/RxJava/issues/4821","id":187947816,"number":4821,"title":"Question: Observable no longer throwing MissingBackpressureException","user":{"login":"balamaci","id":310160,"avatar_url":"https://avatars.githubusercontent.com/u/310160?v=3","gravatar_id":"","url":"https://api.github.com/users/balamaci","html_url":"https://github.com/balamaci","followers_url":"https://api.github.com/users/balamaci/followers","following_url":"https://api.github.com/users/balamaci/following{/other_user}","gists_url":"https://api.github.com/users/balamaci/gists{/gist_id}","starred_url":"https://api.github.com/users/balamaci/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/balamaci/subscriptions","organizations_url":"https://api.github.com/users/balamaci/orgs","repos_url":"https://api.github.com/users/balamaci/repos","events_url":"https://api.github.com/users/balamaci/events{/privacy}","received_events_url":"https://api.github.com/users/balamaci/received_events","type":"User","site_admin":false},"labels":[{"id":24234455,"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":2,"created_at":"2016-11-08T09:57:47Z","updated_at":"2016-11-08T10:28:24Z","closed_at":"2016-11-08T10:28:24Z","body":"Hello, \r\nI understand as with RxJava2.x that Observable is not backpressure aware by default.\r\nI had a piece of code that I was expecting to throw MissingBackpressureException. It did with RxJava1.x\r\n\r\n```\r\nObservable.create(subscriber -> {\r\n            log.info(\"Started emitting\");\r\n\r\n            for (int i = 0; i < 200; i++) {\r\n                log.info(\"Emitting {}\", i);\r\n                subscriber.onNext(i);\r\n            }\r\n\r\n            subscriber.onComplete();\r\n        });\r\nobservable = observable\r\n                .observeOn(Schedulers.io());\r\n        CountDownLatch latch = new CountDownLatch(1);\r\n        observable.subscribe(slowObserver(latch));\r\n        Helpers.wait(latch);\r\n\r\n\r\n    private <T> Observer<T> slowObserver(CountDownLatch latch) {\r\n        return new Observer<T>() {\r\n            @Override\r\n            public void onSubscribe(Disposable d) {\r\n            }\r\n\r\n            @Override\r\n            public void onNext(Object value) {\r\n                log.info(\"Got {}\", value);\r\n                Helpers.sleepMillis(100);\r\n            }\r\n\r\n            @Override\r\n            public void onError(Throwable err) {\r\n                log.error(\"Subscriber got error\", err);\r\n                latch.countDown();\r\n            }\r\n\r\n            @Override\r\n            public void onComplete() {\r\n                log.info(\"Completed\");\r\n                latch.countDown();\r\n            }\r\n        };\r\n    }\r\n```\r\nI see that the buffer size should be Integer.getInteger(\"rx2.buffer-size\", 128) - and it's 128 in my case, however no exception is thrown."},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/259100979","html_url":"https://github.com/ReactiveX/RxJava/issues/4821#issuecomment-259100979","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4821","id":259100979,"user":{"login":"balamaci","id":310160,"avatar_url":"https://avatars.githubusercontent.com/u/310160?v=3","gravatar_id":"","url":"https://api.github.com/users/balamaci","html_url":"https://github.com/balamaci","followers_url":"https://api.github.com/users/balamaci/followers","following_url":"https://api.github.com/users/balamaci/following{/other_user}","gists_url":"https://api.github.com/users/balamaci/gists{/gist_id}","starred_url":"https://api.github.com/users/balamaci/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/balamaci/subscriptions","organizations_url":"https://api.github.com/users/balamaci/orgs","repos_url":"https://api.github.com/users/balamaci/repos","events_url":"https://api.github.com/users/balamaci/events{/privacy}","received_events_url":"https://api.github.com/users/balamaci/received_events","type":"User","site_admin":false},"created_at":"2016-11-08T10:28:24Z","updated_at":"2016-11-08T10:28:24Z","body":"Ok, I understand. Thanks for explaining it."}}
{"actor":{"display_login":"balamaci"}}