Scribd
Upload
15 views

Rxjs Terms and Syntax Slides

The document discusses Observables in Angular and JavaScript. It shows how to create Observables from arrays and events, subscribe to Observables, and unsubscribe. Operators like of, from, interval are demonstrated.

Uploaded by

king kane
Copyright
© © All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd
15 views

Rxjs Terms and Syntax Slides

The document discusses Observables in Angular and JavaScript. It shows how to create Observables from arrays and events, subscribe to Observables, and unsubscribe. Operators like of, from, interval are demonstrated.

Uploaded by

king kane
Copyright
© © All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd
You are on page 1/ 34

-

-
-
-
- -

- -

- -

- -
of
from
const observer = {
next: apple => console.log(`Apple was emitted ${apple}`),
error: err => console.log(`Error occurred: ${err}`),
complete: () => console.log(`No more apples, go home`)
};
const observer = {
next: apple => console.log(`Apple was emitted ${apple}`),
error: err => console.log(`Error occurred: ${err}`),
complete: () => console.log(`No more apples, go home`)
};

const appleStream = new Observable(appleObserver => {


appleObserver.next('Apple 1');
appleObserver.next('Apple 2');
appleObserver.complete();
});
const observer = {
next: apple => console.log(`Apple was emitted ${apple}`),
error: err => console.log(`Error occurred: ${err}`),
complete: () => console.log(`No more apples, go home`)
};
const appleStream = new Observable(appleObserver => {
appleObserver.next('Apple 1');
appleObserver.next('Apple 2');
appleObserver.complete();
});
const sub = appleStream.subscribe(observer);
const observer = {
next: apple => console.log(`Apple was emitted ${apple}`),
error: err => console.log(`Error occurred: ${err}`),
complete: () => console.log(`No more apples, go home`)
};

const sub = appleStream.subscribe(observer);

const sub = appleStream.subscribe(


apple => console.log(`Apple was emitted ${apple}`),
err => console.log(`Error occurred: ${err}`),
() => console.log(`No more apples, go home`)
);
const appleStream = new Observable(appleObserver => {
appleObserver.next('Apple 1');
appleObserver.next('Apple 2');
appleObserver.complete();
});

const sub = appleStream.subscribe(


apple => console.log(`Apple was emitted ${apple}`),
err => console.log(`Error occurred: ${err}`),
() => console.log(`No more apples, go home`)
);
const sub = appleStream.subscribe(observer);

sub.unsubscribe();
const appleStream = new Observable(appleObserver => {
appleObserver.next('Apple 1');
appleObserver.next('Apple 2');
appleObserver.complete();
});

const sub = appleStream.subscribe(


apple => console.log(`Apple was emitted ${apple}`),
err => console.log(`Error occurred: ${err}`),
() => console.log(`No more apples, go home`)
);

sub.unsubscribe();
const appleStream = new Observable(appleObserver => {
appleObserver.next('Apple 1');
appleObserver.next('Apple 2');
appleObserver.complete();
});

const appleStream = of('Apple1', 'Apple2');

const appleStream = from(['Apple1', 'Apple2']);


const apples = ['Apple 1', 'Apple 2'];

of(apples); from(apples);
// [Apple1, Apple2] // Apple1 Apple2

of(...apples);
// Apple1 Apple2
@ViewChild('para') par: ElementRef;

ngAfterViewInit() {
const parStream = fromEvent(this.par.nativeElement, 'click')
.subscribe(console.log)
}

const num = interval(1000).subscribe(console.log);


- of
- from
-

-
-

-
-
-
-

-
-
-
-
-

const sub = appleStream.subscribe(


apple => console.log(`Emitted: ${apple}`),
err => console.log(`Error: ${err}`),
() => console.log(`No more apples, go home`)
);
-

sub.unsubscribe();

You might also like