Winkel-6 + RxJS 6.0 : Wie push neues element zum array enthaltenen Beobachtbaren

Ich bin empfangen von Daten vom FB-server in Blöcken während der Wiedergabe von Daten erfordert eine Bibliothek, die beharrt auf beobachtbaren Array enthält. Ich bin irgendwie nicht in der Lage zu schieben, eine neue Daten-chunk vorhandenen Daten-chunk array enthaltenen beobachtbaren,

Vom dataservice ich rufe nach Thema des nächsten und versuchen, fügen Sie eine neue calEvent

 this.homeWorkerService.eventSubject.next(calEvent);

Komponente ist, habe ich folgenden code

events$: Observable<Array<CalendarEvent<any>>>;

und ngOnInit, ich bin der Bereitstellung von Daten für es wie

this.events$ = this.service.eventSubject.asObservable();

Könnten Sie bitte vorschlagen, durch die ich hinzufügen können Sie ein neues Ereignis zu beobachten, die bereits im Besitz meiner Veranstaltungen.

PS : ich bin mit diese lib gerendert Kalender und mit remoteDB zu Rendern Ereignisse.

Dank,

InformationsquelleAutor Alok G. | 2018-06-14
  1. 13

    Dein Thema ist hier ein array von CalendarEvent, müssen Sie ein array übergeben von CalendarEvent in der next () - Methode. Ich würde empfehlen die Verwendung einer BehaviorSubject in Ihrem Fall. Hier ein kurzes Beispiel:

    import { Component } from '@angular/core';
import { Observable, BehaviorSubject, of } from 'rxjs';
import { take } from 'rxjs/operators';

@Component({
  selector: 'my-app',
  templateUrl: './app.component.html',
  styleUrls: [ './app.component.css' ]
})
export class AppComponent  {
  obsArray: BehaviorSubject<any[]> = new BehaviorSubject<any[]>([]);
  array$: Observable<any> =  this.obsArray.asObservable();

  constructor() {
  }

  ngOnInit() {
    this.addElementToObservableArray('It works');
  }

  addElementToObservableArray(item) {
    this.array$.pipe(take(1)).subscribe(val => {
      console.log(val)
      const newArr = [...val, item];
      this.obsArray.next(newArr);
    })
  }
}

    Sehen Sie ein live-Beispiel hier: Stackblitz.

    Hoffe, es hilft!

    • Dank Geo 🙂 es geklappt hat, wie ich wollte, es zu sein.
    InformationsquelleAutor GeoAstronaute
  2. 1

    Neben GeoAstronaute Antwort, so würde ich entfernen-Zeug aus der Reihe: 

      removeElementToObservableArray(idx) {
    this.array$.pipe(take(1)).subscribe(val => {
      const arr = this.subject.getValue()
      arr.splice(idx, 1)
      this.subject.next(arr)
    })
  }

    I. E: Ihre ngforloop in den HTML-hätte die let i = index, die einen index zu den Daten, die Sie entfernen wollte. Zweitens, die entfernen-Funktion hat innerhalb der ngforloop tag 🙂

    InformationsquelleAutor byblix
Schreibe einen Kommentar