Angular2 Beobachten - Wie Sie als Nächstes anrufen von außerhalb des Beobachtbaren Konstruktor

Ich bin Aufbau eines service, durch den eine Observable. In diesem service, den ich erhalten externe Funktionsaufrufe, die auslösen sollte, ein Nächster Anruf auf das Beobachtbare, so dass verschiedene Verbraucher bekommen die Abo-Falle. Während Beobachter Konstruktor kann ich rufen weiter und alles funktioniert Super, aber wie kann ich diese außerhalb der Konstruktor so, dass externe Trigger können weiter Anrufe?

private myObservable$: Observable<any>;

Während der service-init mache ich

this.myObservable$ = new Observable(observer => {
    observer.next("initial message");
}

Dann in anderen Methoden des gleichen service möchte ich ausführen zu können, so etwas wie

this.myObservable$.observer.next("next message");

Den oben offensichtlich nicht funktioniert, aber wie kann ich dieses Ziel erreichen?

Ich bin angenommen, ich bin fehlt etwas grundlegendes, da muss es eine Möglichkeit geben, zu emittieren weitere Meldungen außerhalb des sichtbaren ersten Konstruktor

InformationsquelleAutor Joshua Ohana | 2017-01-25
  1. 28

    Sollten Sie eine Betreff für das

    this.myObservable$ = new Subject();

    Und dann können Sie den Anruf an einem beliebigen Punkt:

    this.myObservable$.next(...);

    Oder verwenden Sie abonnieren:

    this.myObservable$.subscribe(...)
    • hah genial, danke! Ich wusste, mir fehlte etwas grundlegendes. Funktioniert wie ein Charme jetzt...
    • Für welche version von Winkel-das wird Arbeit
    • Das ist Reine rxjs - es hat nichts zu tun mit angular.
    • Hinweis: Nur Abonnements, setup, bevor nannte next erhalten neue Werte. Wenn Sie zulassen möchten, dass Abonnements erstellt danach verwenden BehaviorSubject oder ReplaySubject.
    InformationsquelleAutor olsn
  2. 6

    Eigentlich Subject wird für beide Verleger und dem Abonnenten, und hier, ich glaube, Sie brauchen nur zu publizieren, Ihrem Wert, so verwenden Sie einfach Beobachten.

    Mithilfe beobachtbare, ordnen Abonnenten-Klasse-level-variable, und verwenden Sie es, wie unten code

    subscriber: Subscriber<boolean>;

public observe(): Observable<boolean> {

    return new Observable<boolean>(subs => {
      this.subscriber = subs;
    });
  }

public callNext() {

    if (this.subscriber) {
      this.subscriber.next();
      this.subscriber.complete();
    }
  }
    InformationsquelleAutor Ravi Sevta
  3. 3

    Zwei Möglichkeiten:

    1. Machen myObservable$ öffentlich:

      public myObservable$: Observable;

    2. Kapseln die beobachtbaren in ein Thema Strom und bieten einen Helfer-Aufruf weiter:

      export class TestService {
  public myObservable$: Observable;
  private _myObservableSubject: Subject;

  constructor() {
    this._myObservableSubject = new Subject();
    this.myObservable$ = this._myObservableSubject.asObservable();
  }

  public NextMessage(message?: string): void {
    this._myObservableSubject.next(message);  
  }
}
    • Danke, Boyan, der zweite sieht aus wie es funktionieren würde, aber ich werde mit olsn die Antwort von oben, wirkt wesentlich übersichtlicher.
    • Sicher, wir reden über die gleiche Sache. Ich habe meine Antwort aus der Lektüre der Winkel 2 docs. Speziell in diesem Abschnitt, Winkel.io/docs/ts/latest/Kochbuch/...
    • Thema erstreckt sich Beobachten, so brauchen Sie nicht dieser wrapper. Verwenden Sie einfach Thema.
    InformationsquelleAutor Ben Richards
Schreibe einen Kommentar