{"action":"created","issue":{"url":"https://api.github.com/repos/ReactiveX/rxjs/issues/1665","repository_url":"https://api.github.com/repos/ReactiveX/rxjs","labels_url":"https://api.github.com/repos/ReactiveX/rxjs/issues/1665/labels{/name}","comments_url":"https://api.github.com/repos/ReactiveX/rxjs/issues/1665/comments","events_url":"https://api.github.com/repos/ReactiveX/rxjs/issues/1665/events","html_url":"https://github.com/ReactiveX/rxjs/issues/1665","id":151684944,"number":1665,"title":"Feature request: add `onErrorResumeNext`","user":{"login":"danhyun","id":1033018,"avatar_url":"https://avatars.githubusercontent.com/u/1033018?v=3","gravatar_id":"","url":"https://api.github.com/users/danhyun","html_url":"https://github.com/danhyun","followers_url":"https://api.github.com/users/danhyun/followers","following_url":"https://api.github.com/users/danhyun/following{/other_user}","gists_url":"https://api.github.com/users/danhyun/gists{/gist_id}","starred_url":"https://api.github.com/users/danhyun/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/danhyun/subscriptions","organizations_url":"https://api.github.com/users/danhyun/orgs","repos_url":"https://api.github.com/users/danhyun/repos","events_url":"https://api.github.com/users/danhyun/events{/privacy}","received_events_url":"https://api.github.com/users/danhyun/received_events","type":"User","site_admin":false},"labels":[{"id":187400554,"url":"https://api.github.com/repos/ReactiveX/rxjs/labels/status:%20PRs%20welcome","name":"status: PRs welcome","color":"159818","default":false}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":6,"created_at":"2016-04-28T16:20:43Z","updated_at":"2016-12-21T12:32:47Z","closed_at":"2016-05-04T16:36:25Z","body":"According to https://github.com/ReactiveX/rxjs/blob/master/MIGRATION.md we're to file an issue or PR requesting feature additions to RxJS5.\n\nI'd like to have something like `onErrorResumeNext` http://xgrommx.github.io/rx-book/content/observable/observable_methods/onerrorresumenext.html or the ability to continue with the next emitted item.\n\nIn my specific usecase I'm doing something like this:\n\n``` javascript\nRx.Observable.from([1, 2, 3, 4])\n  .map(i => {\n    if (i == 2) {\n       throw new Error('no 2s');\n    }\n    return i;\n  })\n  //.onErrorResumeNext(somefunc) // short circuit to subscriber's on error\n  .do(i => console.log('map 1: ' + i))\n  .map(i => i + 1)\n  //.onErrorResumeNext(somefunc) // short circuit to subscriber's on error\n  .do(i => console.log('map 2: ' + i))\n  .map(i => {\n    if (i & 0 == 0) {\n      throw new Error('no evens');\n    }\n    return i * 2;\n  })\n  .do(i => console.log('map 3: ' + i))\n//.onErrorResumeNext(somefunc) // short circuit to subscriber's on error\n  .subscribe(\n    i => console.log('found ' + i),\n    e => console.log('error ' + e),\n    () => console.log('done')\n  );\n```\n\nRelated JSBin http://jsbin.com/monuyegatu/1/edit?html,js,console\n"},"comment":{"url":"https://api.github.com/repos/ReactiveX/rxjs/issues/comments/268512118","html_url":"https://github.com/ReactiveX/rxjs/issues/1665#issuecomment-268512118","issue_url":"https://api.github.com/repos/ReactiveX/rxjs/issues/1665","id":268512118,"user":{"login":"omerts","id":4996164,"avatar_url":"https://avatars.githubusercontent.com/u/4996164?v=3","gravatar_id":"","url":"https://api.github.com/users/omerts","html_url":"https://github.com/omerts","followers_url":"https://api.github.com/users/omerts/followers","following_url":"https://api.github.com/users/omerts/following{/other_user}","gists_url":"https://api.github.com/users/omerts/gists{/gist_id}","starred_url":"https://api.github.com/users/omerts/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/omerts/subscriptions","organizations_url":"https://api.github.com/users/omerts/orgs","repos_url":"https://api.github.com/users/omerts/repos","events_url":"https://api.github.com/users/omerts/events{/privacy}","received_events_url":"https://api.github.com/users/omerts/received_events","type":"User","site_admin":false},"created_at":"2016-12-21T12:32:47Z","updated_at":"2016-12-21T12:32:47Z","body":"Just to add, if I understood the RXJava operator right, what we need is: onExceptionResumeNext\r\n`onExceptionResumeNext - instructs an Observable to continue emitting items after it encounters an exception (but not another variety of throwable)`\r\n"}}
{"actor":{"display_login":"omerts"}}