-
-
-
-
- -
- -
- -
- -
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();
