Issue I was trying to follow this stackoverflow answer for implementing long polling to an API. The issue is that by trying to use Observable.interval() or Observable.timer() the call is made only once and the first call is casted only
Continue readingTag: rxjs
multiple calls in get method
Issue ok, I have the following method in an angular-cli service, I use it to update a table in "real time", pipe and tap, they work as I want, the bad thing is that it makes the http.get request constantly
Continue readingRX: Handling Errors in combineList
Issue I’m using the combinedLatest2 in RxDart but I’m still confused about it. This is my code: final validator = StreamTransformer<String, String>.fromHandlers( handleData: (data, sink) => data.isNotEmpty ? sink.add(data) : sink.addError(‘Cannot be empty.’)); final _subject1 = BehaviorSubject<String>(); final stream1 =
Continue readingcombineLatest2 with only the first non-null stream outputs
Issue I have two streams coming from firestore and I need to do a computationally intensive operation only the first time these two streams produce values. I’ve considered combineLatest2(), but as far as I can tell this will execute every
Continue readingcan I reopen stream after closing it in Dart
Issue In my Flutter app, I use a BehaviorSubject() to listen to an email text field. when user successfully log in I called dispose function to close it to avoid memory leaks. In case of the user signs out and
Continue readingRX: Handling Errors in combineList
Issue I’m using the combinedLatest2 in RxDart but I’m still confused about it. This is my code: final validator = StreamTransformer<String, String>.fromHandlers( handleData: (data, sink) => data.isNotEmpty ? sink.add(data) : sink.addError(‘Cannot be empty.’)); final _subject1 = BehaviorSubject<String>(); final stream1 =
Continue readingcombineLatest2 with only the first non-null stream outputs
Issue I have two streams coming from firestore and I need to do a computationally intensive operation only the first time these two streams produce values. I’ve considered combineLatest2(), but as far as I can tell this will execute every
Continue readingcan I reopen stream after closing it in Dart
Issue In my Flutter app, I use a BehaviorSubject() to listen to an email text field. when user successfully log in I called dispose function to close it to avoid memory leaks. In case of the user signs out and
Continue reading