Tag: RXJS-OBSERVABLES
Tengo un proyecto de biblioteca en Angular 12 desde el cual estoy tratando de difundir algunos valores utilizando BehaviorSubject y un servicio compartido. Aquí está el código de mi servicio de difusión: @Injectable({ providedIn: ‘root’ }) export class BroadcastService{ public subject = new BehaviorSubject<any>(null); get(){ return this.subject.asObservable(); } broadcast(data: any){ . . . Read more
Me gustaría exponer un observable en mi servicio, que emite un valor cada vez que se le asigna un valor a un BehaviorSubject (y después de filtrarlo de una lista). Ejemplo de implementación: export class MyService { // Dada una lista de todos los objetos private readonly allObjects$: Observable<someobject[]>; // . . . Read more
Tengo un componente de Angular que muestra datos de un socket. Esta vista también tiene filtrado y búsqueda. El filtrado/búsqueda son controles de formulario de Angular. Utilicé combineLatest para combinar todos los observables de cambio de valor de los controles de formulario de filtrado/búsqueda (que tienen startWith(”)) y mi observable . . . Read more
Tengo un problema con los observables. He preparado stackblitz para simplificar mi problema. Tengo 2 observables (obs1$, obs2$) y un arreglo de números. Quiero esperar a que obs1$ se complete y luego recorrer el arreglo y devolver un observable para cada elemento, ejecutar obs2$. Aquí está el código de la . . . Read more
Tengo una función simple de Rxjs Observables y Operadores para devolver un nuevo Observable. En mi código, estoy usando los operadores filter y map encadenados dentro de un pipe. Desafortunadamente, obtengo el error TS2571: El objeto es de tipo ‘unknown’ dentro del operador filter (parámetro) data. El código es el . . . Read more