Rxjs Subject next() after complete()

javascript rxjs observable observer-pattern rxjs5
Basit picture Basit · Mar 7, 2016 · Viewed 18.4k times · Source

I have service which connects with Subject() to do paging. I'm using next(newData) to pass to subject, which keeps things alive, now I need to use complete() on each ajax call and pass it to subject. but after doing one complete() I'm started get error.

I wanted to know, can we still pass Subject observables still next(newData) if once completed() is already been triggered?

Answer

user3743222 picture user3743222 · Mar 7, 2016

There is some information on subjects from a former question on stack overflow : here. I encourage you to review it.

About your specific question, subjects once completed cannot emit any longer. This is part of the contract they abide by. Depending on the logic and flow of your application, you might:

  • decide not to complete the subject (why indeed are you completing it if you still need it later on?)
  • create a new subject whenever you need one, but then you have to pass it to whoever needs it.

Related questions

Return an empty Observable

The function more() is supposed to return an Observable from a get request export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> => { …

Read More
How to make one Observable sequence wait for another to complete before emitting?

Say I have an Observable, like so: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); Then, I have a second Observable: var two = someOtherObservable.take(1); Now, I want to subscribe() to two, but I want to make sure that …

Read More
Simple filter on array of RXJS Observable

I am starting my project with Angular2 and the developers seem to recommend RXJS Observable instead of Promises. I have achieved to retrieve a list of elements (epics) from the server. But how can I filter the elments by using …

Read More