{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3813","repository_url":"https://api.github.com/repos/ReactiveX/RxJava","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3813/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3813/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3813/events","html_url":"https://github.com/ReactiveX/RxJava/issues/3813","id":144837945,"number":3813,"title":"OnSubscribeCombineLatest#MultiSourceProducer request method get different result?","user":{"login":"turbof","id":5610070,"avatar_url":"https://avatars.githubusercontent.com/u/5610070?v=3","gravatar_id":"","url":"https://api.github.com/users/turbof","html_url":"https://github.com/turbof","followers_url":"https://api.github.com/users/turbof/followers","following_url":"https://api.github.com/users/turbof/following{/other_user}","gists_url":"https://api.github.com/users/turbof/gists{/gist_id}","starred_url":"https://api.github.com/users/turbof/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/turbof/subscriptions","organizations_url":"https://api.github.com/users/turbof/orgs","repos_url":"https://api.github.com/users/turbof/repos","events_url":"https://api.github.com/users/turbof/events{/privacy}","received_events_url":"https://api.github.com/users/turbof/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/ReactiveX/RxJava/labels/Question","name":"Question","color":"cc317c"}],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":6,"created_at":"2016-03-31T09:17:24Z","updated_at":"2016-04-01T08:39:23Z","closed_at":null,"body":"In request method,there is a line code ':o.unsafeSubscribe(s);' and I fnd the unsafeSubscribe()'s note is 'Subscribes to an Observable and invokes {@link OnSubscribe} function without any contract protection,error handling, unsubscribe, or execution hooks.'.\r\nThis is my code:\r\n```java\r\nObservable<Long> observable1 = Observable.interval(0, 1000, TimeUnit.MILLISECONDS)\r\n                    .map(new Func1<Long, Long>() {\r\n                        @Override\r\n                        public Long call(Long aLong) {\r\n                            return aLong * 5;\r\n                        }\r\n                    }).take(5);\r\n            Observable<Long> observable2 = Observable.interval(500, 1500, TimeUnit.MILLISECONDS)\r\n                    .map(new Func1<Long, Long>() {\r\n                        @Override\r\n                        public Long call(Long aLong) {\r\n                            return aLong * 10;\r\n                        }\r\n                    }).take(4);\r\n            Observable.combineLatest(observable2, observable1, new Func2<Long, Long, Long>() {\r\n                @Override\r\n                public Long call(Long aLong, Long aLong2) {\r\n                    Log.i(\"ppppp\", \"combineLatest aLong = \" + aLong + \"   aLong2 =\" + aLong2);\r\n                    return aLong + aLong2;\r\n                }\r\n            }).subscribe(new Subscriber<Long>() {\r\n                @Override\r\n                public void onCompleted() {\r\n                    System.out.println(\"Sequence complete.\");\r\n                }\r\n                @Override\r\n                public void onError(Throwable e) {\r\n                    System.err.println(\"Error: \" + e.getMessage());\r\n                }\r\n                @Override\r\n                public void onNext(Long aLong) {\r\n                    System.out.println(\"combineLatest Next: \" + aLong);\r\n                }\r\n            });\r\n```\r\n\r\nI run this code and get two different results.\r\n(1)\r\n Next: 0\r\n Next: 5\r\n Next: 10\r\n Next: 20\r\n Next: 25\r\n Next: 35\r\n Next: 40\r\n Next: 50\r\n(2)\r\n Next: 0\r\n Next: 5\r\n Next: 15\r\n Next: 20\r\n Next: 25\r\n Next: 35\r\n Next: 40\r\n Next: 50"},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/204309605","html_url":"https://github.com/ReactiveX/RxJava/issues/3813#issuecomment-204309605","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/3813","id":204309605,"user":{"login":"turbof","id":5610070,"avatar_url":"https://avatars.githubusercontent.com/u/5610070?v=3","gravatar_id":"","url":"https://api.github.com/users/turbof","html_url":"https://github.com/turbof","followers_url":"https://api.github.com/users/turbof/followers","following_url":"https://api.github.com/users/turbof/following{/other_user}","gists_url":"https://api.github.com/users/turbof/gists{/gist_id}","starred_url":"https://api.github.com/users/turbof/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/turbof/subscriptions","organizations_url":"https://api.github.com/users/turbof/orgs","repos_url":"https://api.github.com/users/turbof/repos","events_url":"https://api.github.com/users/turbof/events{/privacy}","received_events_url":"https://api.github.com/users/turbof/received_events","type":"User","site_admin":false},"created_at":"2016-04-01T08:39:22Z","updated_at":"2016-04-01T08:39:22Z","body":"@akarnokd thanks for your reply.Your sample is awesome.(ps:Did you find my english is very poor? )"}}