devmobasa’s gists

devmobasa / observable-subscribe-to-mouse-event.ts

Created April 26, 2017 05:15

RxJS fromEvent - Take 10 - Subscribing to mouse events - Coding Blast - www.codingblast.com

devmobasa / observable-interval.ts

Created April 26, 2017 05:46

RxJS - Observable.interval - simple - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	Observable
	.interval(1000)
	.subscribe(function next(value) {
	console.log('next: ', value);
	});

devmobasa / observable-interval.ts

Created April 26, 2017 05:49

RxJS - Observable.interval - simple - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	Observable
	.interval(1000)
	.take(10)
	.subscribe(function next(value) {
	console.log('next: ', value);
	});

devmobasa / rxjs-cold-observable.ts

Created April 26, 2017 06:56

RxJS - Cold observable - Two Subscribers - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	let source = Observable
	.interval(1000)
	.take(6);

	source.subscribe(x => console.log('sub 1: ', x));

	setTimeout(function () {
	source.subscribe(x => console.log(' sub 2: ', x));

devmobasa / rxjs-hot-observable.ts

Created April 26, 2017 06:56

RxJS - Hot Observable - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	let source = Observable
	.interval(1000)
	.take(6)
	.publish()
	.refCount();

	source.subscribe(x => console.log('sub 1: ', x));

devmobasa / simple-generator-in-out.js

Created April 26, 2017 16:20

Generators Simple pause resume - Coding Blast - www.codingblast.com

	function* print() {
	let a = 5 - (yield 3);
	console.log('a:', a);
	}

	let generator = print();

	let iteratorResult = generator.next(); // sending value in next here gets ignored during first next
	console.log(iteratorResult);

devmobasa / rxjs-simple-operators.ts

Created April 27, 2017 18:11

RxJS simple operators - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	let numbers = [1, 2, 3, 4];

	let source = Observable
	.from(numbers)
	.map(n => n * 2)
	.filter(n => n > 5)
	.reduce((accumulator, currentValue) => accumulator + currentValue);

devmobasa / simple-promise.js

Created April 27, 2017 18:24

Promise JavaScript - Coding Blast - www.codingblast.com

	function iGiveYouAPromise(value: number) {
	return new Promise(function (resolve, reject) {
	if (value === 4141) {
	reject('Number is too weird..')
	} else {
	setTimeout(function () {
	resolve('Success!');
	}, 1500);
	}
	});

devmobasa / rxjs-promise-observable.ts

Created April 27, 2017 18:31

Promise and Observable - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	let promise = new Promise((resolve, reject) => {
	console.log('Promise starts');
	setTimeout(() => {
	resolve('Promise - after timeout of 1500 miliseconds!');
	}, 1500);
	});

	let source = Observable.create((observer) => {

devmobasa / rxjs-promise-observable.ts

Created April 27, 2017 18:32

Promise and Observable - Coding Blast - www.codingblast.com

	import {Observable} from 'rxjs';

	let promise = new Promise((resolve, reject) => {
	console.log('Promise starts');
	setTimeout(() => {
	resolve('Promise - after timeout of 1500 miliseconds!');
	}, 1500);
	});

	let source = Observable.create((observer) => {