Ajouter des variables dans un flux d'Observable

J'ai une variable Observable :

Code:

---

1 2 3 4

export class Thread { id: string; messages: Observable<Message[]>; }

---

Je voudrais ajouter des variables Message à ce flux d'Observable. La variable messages doit contenir une collection de Message.

Code:

---

const newMessage = new Message(objMessage);

---

J'essaye d'utiliser la méthode .net mais cela ne fonctionne pas :

Code:

---

1 2 3

thread.messages = new Observable((observer: any) => { observer.next(newMessage); });

---

Code:

---

1 2 3

thread.messages.subscribe((message: Message) => { thread.messages = message; });

---

Code:

---

1 2 3

thread.messages.subscribe((value: Message[]) => { value.next(newMessage); });

---

Savez-vous s'il est possible d'utiiser la méthode .next sur un flux d'Observable ?

Bonjour bzh.floriane,

J'ai mis en place dans une des mes applications une fonctionnalité d'auto-complétion avec un Observable, voici ce qui fonctionne chez moi (exemple en TypeScript) :

Code:

---

1 2 3 4 5 6

private searchTerms = new Subject<string>();   search(term: string): void { this.searchTerms.next(term); }

---

Ensuite j'ai une autre méthode pour traiter le flux. Voici la démonstration de l'application : https://ng2-pokemon-app.firebaseapp.com/login.

Cordialement,

Simon, auteur sur awesome-angular.

Comme ceci, dans mon cas ?

Code:

---

1 2 3 4 5

private subject = new Subject<Message[]>();   this.subject.next([newMessage]);   thread.messages = this.subject:

---

Cela fonctionne mais ma variable thread.messages ne contient pas tous les messages, elle ne contient que un message à la fois.
Sais-tu comment obtenir une pile de messages dans ma variable thread.messages.

Bonjour bzh.floriane,

A la ligne 2, je pense que tu réinitialise ton Observable en lui passant un tableau contenant ton message plutôt que ton message directement :

Code:

---

1 2 3 4

this.subject.next([newMessage]); // Tableau contenant ton message, essaye ceci plutôt :   this.subject.next(newMessage);

---

En espérant que ça marchera, 8-)

Simon,

auteur sur AwesomeAngular.

Non, cela ne fonctionne pas car ma variable Subject est un tableau.
Voici l'erreur :

Code:

---

Argument of type 'Message' is not assignable to parameter of type 'Message[]'

---

Bonjour,

L'erreur affiche est logique en effet. :)

Au niveau de la déclaration de votre Observable, déclarez bien un flux de Message et non un flux de tableau de Message :

Code:

---

1 2	private subject = new Subject<Message>();

---

L'Observable contiendra bien une suite d'objet de type Message. Est-ce que cela fonctionne avec cette modification ?