Discussion :

[bzh.floriane]

J'ai une variable Observable :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

const newMessage = new Message(objMessage);

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 ?

[LearningBoy]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[bzh.floriane]

Comme ceci, dans mon cas ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[LearningBoy]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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,

Simon,

auteur sur AwesomeAngular.

[bzh.floriane]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[LearningBoy]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 ?