I'm trying to authenticate to an API first and then "attach" the token to each one of my requests, but the one including 'connect'. I have the following: Interceptor @Injectable() export class TokenInterceptor implements HttpInterceptor { constructor(private authService: AuthService) {}…
I am trying to create refetch functionality. The problem is that because values$ and retryGetValues have different subscribers, my component is not re-rendering. How can I make it so that values$ is recalculated when I press my retry button? export…
I am working on an angular v14 application and I am having trouble figuring out how to fix an issue with my component making duplicate api calls. I have a service that is shared between all components to set and…
I'm surprised by the order of the output of this Observable example: <script type="module"> import { of } from 'https://dev.jspm.io/rxjs@6'; console.log("1. before subscribe"); of(["asd"]).subscribe(paramMap => { console.log("2. in subscribe"); }); console.log("3. after subscribe"); </script> This produces this output: 1. before…
I'm completely new to rxjs and trying to accomplish one task - essentially I need a Promise-like API with the following differences: Unlike the standard Promise my API should be able to resolve multiple times. When calling await/then the last…
Says, I have an api call that take an input since which is Unix timestamp. fetchData = (since?) => { const now = Math.floor(Date.now() / 1000); // Current Unix timestamp in seconds if (since) { //handle logic console.log(since) } return…
I'm having trouble understanding how to use async/await in this scenario. I have a function GetAdditionalProducts() that calls a service and returns a result. I call that function elsewhere where I need access to that result but it executes that…
I am attempting to do in order async manipulation of strings in an array. The class has an array of objects that have a transform method that return an observable. Each transform call depends on the output of the prior.…
I am trying to execute a method 1000 milliseconds after all items in pipe finish, and I don't want the result, nor do I want it to change the current value of the pipe. What I have here is what…
I'm sending some values to an rxjs pipe followed by a subscription. In case of errors, I want to ignore them and continue with the remaining inputs. of('foo', 'bar', 'error', 'bazz', 'nar', 'error', 'car').subscribe(...) So I did this: async function…