The parallel operator proved to be a problem for almost all use cases and does not do what most expect from it, so it was removed in the 1.0.0.rc.4 release: https://github.com/ReactiveX/RxJava/pull/1716 A good example of how to do this type of behavior and get parallel execution can be seen here. In your example code it … Read more
The correct way for Angular (ver. 2+): it(‘retrieves all the cars’, waitForAsync(inject([CarService], (carService) => { carService.getCars().subscribe(result => expect(result.length).toBeGreaterThan(0)); })); Async Observables vs Sync Observables It is important to understand that Observables can be either synchronous or asynchronous. In your specific example the Observable is asynchronous (it wraps an http call). Therefore you have to use … Read more
UPDATE: As of rxjs 6.0.0-beta.3, operators and observable creators should be imported from rxjs. Furthermore, fromPromise is not part of the public API anymore and its wrapped in the from method. TL;DR; UPDATE For rxjs 6.0.0 use: import { from } from ‘rxjs’; var observableFromPromise = from(promiseSrc); UPDATE: After the release of the pipeable operators … Read more
Using the following imports: import {Observable} from ‘rxjs/Observable’; import ‘rxjs/add/observable/of’; import ‘rxjs/add/operator/delay’; Try this: let fakeResponse = [1,2,3]; let delayedObservable = Observable.of(fakeResponse).delay(5000); delayedObservable.subscribe(data => console.log(data)); UPDATE: RXJS 6 The above solution doesn’t really work anymore in newer versions of RXJS (and of angular for example). So the scenario is that I have an array of … Read more
JohnWowUs’ answer is great and helped me understand how to avoid the recursion effectively, but there were some points I was still confused about, so I’m posting my tweaked version. Summary: The individual pages are returned as a Single. Use a Flowable to stream each of the items contained in the pages. This means callers … Read more
update (2.0.0 final) (somepath/:someparam/someotherpath) you can subscribe to them using _router.queryParams.subscribe(…): export class HeroComponent implements OnInit { constructor(private _activatedRoute: ActivatedRoute, private _router:Router) { _activatedRoute.queryParams.subscribe( params => console.log(‘queryParams’, params[‘st’])); original If you want queryParams instead of route params (somepath/:someparam/someotherpath) you can subscribe to them using _router.routerState.queryParams.subscribe(…): export class HeroComponent implements OnInit { constructor(private _activatedRoute: ActivatedRoute, private … Read more
In my case the error occurred only during e2e tests. It was caused by throwError in my AuthenticationInterceptor. I imported it from a wrong source because I used WebStorm’s import feature. I am using RxJS 6.2. Wrong: import { throwError } from ‘rxjs/internal/observable/throwError’; Correct: import { throwError } from ‘rxjs’; Here the full code of … Read more
Your people object isn’t an array so you can iterate over it out of the box. There is two options: You want to iterate over a sub property. For example: <ul> <li *ngFor=”#person of people?.actionList?.list”> {{ person.label }} </li> </ul> You want to iterate over the keys of your object. In this case, you need … Read more
Based on the library http://goessner.net/download/prj/jsonxml/, I implemented a sample to receive XML data and parse them into an Angular2 application: var headers = new Headers(); (…) headers.append(‘Accept’, ‘application/xml’); return this.http.get(‘https://angular2.apispark.net/v1/companies/’, { headers: headers }).map(res => JSON.parse(xml2json(res.text(),’ ‘))); To be able to use the library, you need to parse first the XML string: var parseXml; if … Read more
With the new syntax of RxJS 5.5+, this becomes as the following: // RxJS 6 import { EMPTY, empty, of } from “rxjs”; // rxjs 5.5+ (<6) import { empty } from “rxjs/observable/empty”; import { of } from “rxjs/observable/of”; empty(); // deprecated use EMPTY EMPTY; of({}); Just one thing to keep in mind, EMPTY completes … Read more