7.2 RXJS : creation transformation filtering - quan1997ap/angular-app-note GitHub Wiki

1. creation

Observable

• next => bắn ra giá trị gì
• error => bắn ra lỗi
• complete => kết thúc

Chú ý:

Observable chỉ emit 1 trong 2. Hoặc là error, hoặc là value. Sau khi gọi hàm complete. Thì các function next, error sẽ không hoạt động nữa.

import { Observable } from 'rxjs';

// Case 1: next value
    const locations$ = new Observable((observer) => {
      // next value
      observer.next('position');
      // complete
      observer.complete()
    });

// Case 2: next error
    const locations$ = new Observable((observer) => {
      // next error
      observer.error('Geolocation not available');
      // complete
      observer.complete()
    });

// Case 3: subscribe
    locations$.subscribe(
      x => console.log('Observer got a next value: ' + x),
      err => console.error('Observer got an error: ' + err),
      () => console.log('Observer got a complete notification')
    );

2. transformation

3. filtering