Top "Observable" questions

An observable is typically a programming construct that can be "watched" by other parts of the code, called the "observers". Different frameworks and programming languages have different implementations for observables, so this tag should typically be used in conjunction with others.

Angular 6 + RxJS 6.0 : How to push new element to array contained by Observable

I am receiving data from firebase server in chunks while rendering that data requires a library which insists on observable …

angular rxjs observable subject
RxJS - subscribe only once but do not complete Observable

imagine situation when you have some Observable that contains data that changes in real time, example below... interface User { name: …

angular rxjs observable subscription unsubscribe
Alternative to Java's Observable class?

I'm coming to Java from the C# world where the Observer pattern is implemented as a first-class language construct with …

java events observer-pattern observable
How to convert rxJava2's Observable to Completable?

I have Observable stream, and I want to convert it to Completable, how I could do that?

java observable rx-java reactive-programming rx-java2
Angular 2 pipe, using observable correctly, my pipe does not return a poster path

I'm trying to call my service to get a poster Url for all my movies (Want to show the poster …

angular pipe observable subscribe
How to run 2 queries sequentially in a Android RxJava Observable?

I want to run 2 asynchronous tasks, one followed by the other (sequentially). I have read something about ZIP or Flat, …

android rx-java observable subscriber retrolambda
Angular 2 Cannot read property 'subscribe' of undefined TypeError: Cannot read property 'subscribe' of undefined

I have tried many propositions on fixing this error here on stackoverflow, but now I just need to ask as …

angular observable subscribe
What's the observable equivalent to `Promise.reject`

I had this code return this.http.get(this.pushUrl) .toPromise() .then(response => response.json().data as PushResult[]) .catch(…

http angular promise observable
Observable.forkJoin with a for loop

I am trying to populate an array in my component called processes which is an array of process. Each process …

javascript angular observable angular2-observables
RxJS5 finalize operator not called

I'm trying to trigger a callback when all my observables are executed. In my other, older project i used finally …

angular rxjs observable rxjs5