{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4198","repository_url":"https://api.github.com/repos/ReactiveX/RxJava","labels_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4198/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4198/comments","events_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4198/events","html_url":"https://github.com/ReactiveX/RxJava/issues/4198","id":165411687,"number":4198,"title":"Merge of Observable using SyncOnSubscribe and PublishSubject does not work ","user":{"login":"Witko","id":658494,"avatar_url":"https://avatars.githubusercontent.com/u/658494?v=3","gravatar_id":"","url":"https://api.github.com/users/Witko","html_url":"https://github.com/Witko","followers_url":"https://api.github.com/users/Witko/followers","following_url":"https://api.github.com/users/Witko/following{/other_user}","gists_url":"https://api.github.com/users/Witko/gists{/gist_id}","starred_url":"https://api.github.com/users/Witko/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/Witko/subscriptions","organizations_url":"https://api.github.com/users/Witko/orgs","repos_url":"https://api.github.com/users/Witko/repos","events_url":"https://api.github.com/users/Witko/events{/privacy}","received_events_url":"https://api.github.com/users/Witko/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,"assignees":[],"milestone":null,"comments":6,"created_at":"2016-07-13T20:18:15Z","updated_at":"2016-07-22T11:10:49Z","closed_at":null,"body":"You can reproduce mentioned behaviour with:\r\n\r\n```\r\n\t@Test\r\n\tpublic void name() throws Exception {\r\n\t\tObservable<String> ahoj =\r\n\t\t\t\tObservable.create(SyncOnSubscribe.createStateless(o -> {\r\n\t\t\t\t\to.onNext(\"ahoj\");\r\n\t\t\t\t\ttry {\r\n\t\t\t\t\t\tsleep(50);\r\n\t\t\t\t\t} catch (InterruptedException e) {\r\n\t\t\t\t\t\te.printStackTrace();\r\n\t\t\t\t\t}\r\n\t\t\t\t}));\r\n\t\tPublishSubject<String> subject = PublishSubject.create();\r\n\r\n\t\tObservable.merge(ahoj, subject)\r\n\t\t\t\t.subscribeOn(Schedulers.io())\r\n\t\t\t\t.subscribe(System.out::println);\r\n\r\n\t\tfor (int i = 0; i < 10; i++) {\r\n\t\t\tsubject.onNext(\"Subject!\");\r\n\t\t\tsleep(100);\r\n\t\t}\r\n\t\tsleep(100);\r\n\t}\r\n```\r\n\r\nThis never writes \"Subject!\"\r\nWhen tried with  ```ahoj = Observable.just(\"1\", \"2\", \"3\")``` it worked.\r\n\r\nTested with 1.1.6 & 1.1.7\r\nThanks!"},"comment":{"url":"https://api.github.com/repos/ReactiveX/RxJava/issues/comments/234517962","html_url":"https://github.com/ReactiveX/RxJava/issues/4198#issuecomment-234517962","issue_url":"https://api.github.com/repos/ReactiveX/RxJava/issues/4198","id":234517962,"user":{"login":"Witko","id":658494,"avatar_url":"https://avatars.githubusercontent.com/u/658494?v=3","gravatar_id":"","url":"https://api.github.com/users/Witko","html_url":"https://github.com/Witko","followers_url":"https://api.github.com/users/Witko/followers","following_url":"https://api.github.com/users/Witko/following{/other_user}","gists_url":"https://api.github.com/users/Witko/gists{/gist_id}","starred_url":"https://api.github.com/users/Witko/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/Witko/subscriptions","organizations_url":"https://api.github.com/users/Witko/orgs","repos_url":"https://api.github.com/users/Witko/repos","events_url":"https://api.github.com/users/Witko/events{/privacy}","received_events_url":"https://api.github.com/users/Witko/received_events","type":"User","site_admin":false},"created_at":"2016-07-22T11:10:49Z","updated_at":"2016-07-22T11:10:49Z","body":"Thank you for you help!"}}
{"actor":{"display_login":"Witko"}}