Intenté usar Subject en una multicast para completarla, pero no muestra el mensaje de finalización establecido en el método complete(). ¿Cuál es la razón? ¿Y cómo se supone que deben usarse los métodos error y complete? “`typescript let source = new Observable(subscriber => { subscriber.next(1); subscriber.next(2); return () => { . . . Read more
Tengo el siguiente ejemplo import { Subject } from “rxjs”; const subject = new Subject(); subject.subscribe(() => new Promise(res => { setTimeout(() => console.log(‘!! 1’), 500); })) subject.subscribe(() => new Promise(res => { setTimeout(() => console.log(‘!! 2’), 1000); })) console.log(‘>>> START’) subject.next(); console.log(‘<<< FINISH’) La consola se ve así >>> . . . Read more
Tengo un marco de datos como este: mydata <- data.frame(Id=c(01,01,01,01,01,01,02,02,02,02), VISIT=c(“Screeing”,”Baseline”,”Baseline”,”Baseline”,”Week 9″,”Week 9″,”Baseline”,”Week 2″, “Week 2″,”Week 2”), Score=c(1,2,4,5,78,9,5,NA,3,4)) Lo que intento hacer es agrupar por Id y VISIT y elegir el primer valor no NA de cada grupo: mydata %>% group_by(Id,VISIT) %>% mutate(first = dplyr::first(na.omit(Score))) Pero esto no elimina las . . . Read more
¿Puedo cancelar la suscripción de un evento RxJs utilizando takeUntil con un Subject dentro? Mi código de ejemplo es así: private _closed$: Subject = new Subject<boolean>(); fromEvent(document, ‘mousedown’) .pipe(takeUntil(this._closed$)); Pero el problema es que mi linting me muestra el error: Argumento de tipo ‘Observable<unknown>’ no es asignable a parámetro de . . . Read more
Estoy enviando una solicitud al servidor para modificar uno de los usuarios. Como respuesta, el servidor devuelve el usuario actualizado. Después de eso, intento actualizar BehaviorSubject de todos los usuarios de esta manera: private currentHeroes = new BehaviorSubject<hero[]>(null); currentHeroes$ = this.currentHeroes.asObservable(); powerUp(id: number) { return this.http .post<hero>(environment.apiUrl + ‘heroes/powerUp/’ + . . . Read more