You are not calling the getVideos method. You are calling subscribe on the function reference of getVideos and not the returned value. Call subscribe after you call getVideos(): ngOnInit() { this.videoserv.getvideos().subscribe((response) => { this.videos = response }); }
For ObservableObject the pairing ObservedObject makes view refresh, so to solve the task in question I would recommend the following approach: Demo Code import SwiftUI import Combine class Sport: ObservableObject, Hashable, Identifiable { static func == (lhs: Sport, rhs: Sport) -> Bool { lhs.name == rhs.name && lhs.isFavorite == rhs.isFavorite && lhs.school == rhs.school } … Read more
The .subscribe() function is similar to the Promise.then(), .catch() and .finally() methods in jQuery, but instead of dealing with promises it deals with Observables. That means it will subscribe itself to the observable of interest (which is getTasks() in your case) and wait until it is successful and then execute the first passed callback function … Read more
If this.contacts is an Observable of list of objects (contacts: Observable<Items[]>) and you want to make some changes to that list, you can simply use tap: import { tap } from ‘rxjs/operators’; this.contacts.pipe(tap(usersList => { usersList.push(newItem); })); But if you want to make another request to the server and merge these lists, you can use … Read more
The best answer you’ll find is Pascal Precth’s one who explained that on a dedicated issue asked in December 2015: “Do Observables make sense for http?” (but feel free to read along, plenty of additional answers are really good too!) On top of my head: – Retry – Cancel – Enjoy all the Rxjs operators … Read more
You can use promises with async/await async getUser() { if (this.storage.token == null || this.storage.token == ”) { return; } const t = await this.net.get<LoginModel>(`Authentication/GetUser`).toPromise(); this.storage.token = t.token; this.storage.user = t.user; console.log(this.storage.user); } See more: Promises async await ES8 async/await async/await tutorial async/await explained
Probably a bit late, but you could leverage the help of rxjs-spy. This solution is equivalent the proposed one, and, in my opinion, better maintainable. I usually enable it globally in main.ts as a fire and forget strategy. You simply have to: install rxjs-spy via your package manager import in main.ts the reference to the … Read more
private handleError(error: any) { // previously // return Observable.throw(‘Some error information’); // now return throwError(‘Some error information’); } See also How to catch exception correctly from http.request()?
Here’s a way where you can share the subscription and not have to make any custom pipe: <ng-container *ngIf=”{value: obs$ | async} as context”> {{context.value}} </ng-container> The *ngIf will evaluate to true no matter what (I believe) and then you can do your own tests on the value in the context object. …would be better … Read more
You need to apply the limit to the retry signal, for instance if you only wanted 10 retries: loadSomething(): Observable<SomeInterface> { return this.http.get(this.someEndpoint, commonHttpHeaders()) .retryWhen(errors => // Time shift the retry errors.delay(500) // Only take 10 items .take(10) // Throw an exception to signal that the error needs to be propagated .concat(Rx.Observable.throw(new Error(‘Retry limit exceeded!’)) … Read more