Skip to main content

Introdução | Rxjs

  • Introdução | Rxjs
info

alt text

Observer​

info
  • Um Observer é um consumidor de valores que são entregues por um Observable. Ele recebe e responde

No RxJS, um Observer é definido como uma interface com os seguintes métodos:

  • next()
  • error()
  • complete()

Exemplo

import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs';

@Component({
  selector: 'app-exemplo-observer',
  template: `<p>{{ mensagem }}</p>`
})
export class ExemploObserverComponent implements OnInit {
  mensagem = '';

  ngOnInit() {
    const observable$ = new Observable<string>(subscriber => {
      subscriber.next('Olá do Observable!');
      subscriber.complete();
    });

    observable$.subscribe({
      next: valor => this.mensagem = valor,
      complete: () => console.log('Observable completo')
    });
  }
}

Subscribe​

É um Observer que pode se desinscrever de um Observable.

Observable​

  • É uma coleção de eventos ou valores emitidos ao longo do tempo
    • Ações do usuário
    • Reposta
  • Pode emitir: tipos primitivos, eventos, objetos, arrays, resposta http
danger

O Observable normalmente é unidirecional conforme a imagem abaixo:

alt text

Subscription​

  • Informa ao Observable que o subscriber está pronto para receber notificações