Skip to content

Instantly share code, notes, and snippets.

@devmobasa
devmobasa / rxjs-simple-operators.ts
Last active April 26, 2017 04:55
RxJS simple operators - Coding Blast - www.codingblast.com
import { Observable } from 'rxjs';
let numbers = [1, 2, 3];
let source = Observable
.from(numbers)
.map(n => n * 2)
.filter(n => n > 5);
@devmobasa
devmobasa / creating-observable-error.ts
Last active April 26, 2017 04:54
Creating observable error - Coding Blast - www.codingblast.com
import { Observable } from 'rxjs';
let words = ['coding blast', 'badword', 'coding', 'blast'];
let source = Observable.create(observer =>{
for (let word of words) {
if (word === 'badword') {
observer.error('Bad word!');
}
@devmobasa
devmobasa / creating-observable-error-no-error-method.ts
Last active April 26, 2017 04:54
Creating observable error - no error method - Coding Blast - www.codingblast.com
source.subscribe(next);
function next(value: any) {
console.log('next: ', value);
}
@devmobasa
devmobasa / simple-observer-create-multiple-subscribers.ts
Last active April 26, 2017 04:54
Simple observer create and multiple subscribers - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let words = ['coding blast', 'coding', 'blast'];
let source = Observable.create(observer => {
for (let word of words) {
observer.next(word);
}
observer.complete();
});
@devmobasa
devmobasa / creating-observable-error.ts
Last active April 26, 2017 04:54
Creating observable error - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let words = ['coding blast', 'badword', 'coding', 'blast'];
let source = Observable.create(observer => {
for (let word of words) {
if (word === 'badword') {
observer.error('Bad word!');
}
@devmobasa
devmobasa / creating-observable-error.ts
Last active April 26, 2017 04:54
Creating Observable error - error method on observer - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let words = ['coding blast', 'badword', 'coding', 'blast'];
let source = Observable.create(observer => {
for (let word of words) {
if (word === 'badword') {
observer.error('Bad word!');
}
@devmobasa
devmobasa / creating-observable-error.ts
Last active April 26, 2017 04:54
Creating Observable error with throw - error method on observer - Coding Blast - www.codingblast.com
let source = Observable.create(observer => {
for (let word of words) {
if (word === 'badword') {
throw new Error('Bad word!');
}
observer.next(word);
}
observer.complete();
@devmobasa
devmobasa / observable-of.ts
Created April 26, 2017 04:53
Observable.of - creating observable - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let source = Observable
.of('coding blast', 'badword', 'coding', 'blast')
.map(w => w + ' RxJS');
console.log('before subscribe');
source.subscribe(function next(value) {
console.log('Subscriber - next: ', value);
@devmobasa
devmobasa / observable-of.ts
Created April 26, 2017 05:00
Observable.of - creating Observable from arguments - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let source = Observable
.of('coding blast', 'badword', 'coding', 'blast')
.map(w => w + ' RxJS');
console.log('before subscribe');
source.subscribe(function next(value) {
console.log('Subscriber - next: ', value);
@devmobasa
devmobasa / observable-subscribe-to-mouse-event.ts
Created April 26, 2017 05:13
RxJS fromEvent - Subscribing to mouse events - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
Observable
.fromEvent(document, 'mousemove')
.forEach(function next(value) {
console.log('next: ', value);
});