We are building a message bus based on observables and using Subjects internally. If one of the consumers throws an error in the subscribe processing code, the Subject no longer emits any errors. This appears to be a known issue but the workaround described here: https://medium.com/@benlesh/on-the-subject-of-subjects-in-rxjs-2b08b7198b93 doesn't work with subjects (only with the example code).
We are building a message bus based on observables and using Subjects internally. If one of the consumers throws an error in the subscribe processing code, the Subject no longer emits any errors. This appears to be a known issue but the workaround described here: https://medium.com/@benlesh/on-the-subject-of-subjects-in-rxjs-2b08b7198b93 doesn't work with subjects (only with the example code).
I've created an example here (see app.ts for the code) http://plnkr.co/edit/N98zZR?p=preview