Top "Reactivex" questions

ReactiveX is a library for composing asynchronous and event-based programs by using observable sequences.

RxJs catch error and continue

I have a list of items to parse, but the parsing of one of them can fail. What is the "…

javascript rxjs reactivex
How can I complete Observable in RxJS

Let's say we have an Observable: var observable = Rx.Observable .fromEvent(document.getElementById('emitter'), 'click'); How can I make it …

javascript stream observable rxjs reactivex
Why are Subjects not recommended in .NET Reactive Extensions?

I am currently getting to grips with the Reactive Extensions framework for .NET and I am working my way through …

c# system.reactive reactivex
Angular 4: Module not found error regarding RxJs

when building the Angular app I get many of these errors, below is just the first one ERROR in ./~/@reactivex/…

angular rxjs reactivex
How do I make an Observable Interval start immediately without a delay?

I want my observable to fire immediately, and again every second. interval will not fire immediately. I found this question …

rxjs reactivex
Observing UITextField.editing with RxSwift

I want to observe the property UITextfield.editing. I'm using this code: self.money.rx_observe(Bool.self, "editing").subscribeNext { (…

ios swift rx-swift reactivex rx-cocoa
Observe array in Swift 3 using RxSwift

To create an observable array using RxSwift in Swift 2, I use to do this: [1, 2, 3].toObservable().subscribeNext { print($0) } But in Swift 3, …

ios swift rx-swift reactivex
BehaviorSubject vs PublishSubject

I'm trying to get my head around the golden rule (if any) about: When to use BehaviorSubject ? and When to …

android rx-java rx-swift reactivex
Difference between Observable.defer and Observable.create in java rx

Can someone explain me the difference between defer and create methods in Observable? I failed to understand when I should …

java reactivex
Subscribe to last value after completed on RxSwift PublishSubject

I'm looking for something like this: let observable = PublishSubject<String>() observable.onNext("1") observable.onCompleted() _ = observable.subscribeNext { s in …

swift rx-swift reactivex