Nicholas Jamieson cartant

RxJS core team member; front-end developer; mentor; speaker; open-source contributor

cartant / medium-rxjs-multicast-take.ts

Created August 18, 2017 07:38

	function takeWhileInclusive<T>(
	predicate: (value: T) => boolean
	): (source: Observable<T>) => Observable<T> {

	return source => source.multicast(
	() => new ReplaySubject<T>(1),
	shared => shared
	.takeWhile(predicate)
	.concat(shared.take(1).filter(t => !predicate(t)))
	);

cartant / medium-rxjs-publish-mental-model.ts

Last active July 20, 2019 15:20

	import { Observable } from "rxjs/Observable";
	import { Subject } from "rxjs/Subject";
	import "rxjs/add/observable/defer";
	import "rxjs/add/observable/of";

	const source = Observable.defer(() => Observable.of(
	Math.floor(Math.random() * 100)
	));

	function observer(name: string) {

cartant / medium-rxjs-publish-naive-multicast.ts

Last active August 23, 2017 02:28

	function multicast<T>(source: Observable<T>) {
	const subject = new Subject<T>();
	source.subscribe(subject);
	return subject;
	}

	const m = multicast(source);
	m.subscribe(observer("a"));
	m.subscribe(observer("b"));

cartant / medium-rxjs-publish-multicast.ts

Created August 23, 2017 03:37

	import { Observable } from "rxjs/Observable";
	import { Subject } from "rxjs/Subject";
	import "rxjs/add/observable/defer";
	import "rxjs/add/observable/of";
	import "rxjs/add/operator/multicast";

	const source = Observable.defer(() => Observable.of(
	Math.floor(Math.random() * 100)
	));

cartant / medium-rxjs-publish-multicast-ref-count.ts

Last active August 23, 2017 06:09

	const m = source.multicast(new Subject<number>()).refCount();
	m.subscribe(observer("a"));
	m.subscribe(observer("b"));

cartant / medium-rxjs-publish-multicast-ref-count-factory.ts

Last active August 23, 2017 06:09

	const m = source.multicast(() => new Subject<number>()).refCount();
	m.subscribe(observer("a"));
	m.subscribe(observer("b"));

cartant / medium-rxjs-publish-multicast-delay.ts

Last active July 20, 2019 22:14

	import { Observable } from "rxjs/Observable";
	import { Subject } from "rxjs/Subject";
	import "rxjs/add/observable/defer";
	import "rxjs/add/observable/of";
	import "rxjs/add/operator/delay";
	import "rxjs/add/operator/multicast";

	const source = Observable.defer(() => Observable.of(
	Math.floor(Math.random() * 100)
	)).delay(0);

cartant / medium-rxjs-publish.ts

Last active July 21, 2019 00:18

	import { Observable } from "rxjs/Observable";
	import "rxjs/add/observable/concat";
	import "rxjs/add/observable/defer";
	import "rxjs/add/observable/of";
	import "rxjs/add/operator/delay";
	import "rxjs/add/operator/publish";

	function random() {
	return Math.floor(Math.random() * 100);
	}

cartant / medium-rxjs-publish-last.ts

Created August 23, 2017 06:10

	const p = source.publishLast();
	p.subscribe(observer("a"));
	p.connect();
	p.subscribe(observer("b"));
	setTimeout(() => p.subscribe(observer("c")), 10);

cartant / medium-rxjs-publish-replay.ts

Created August 23, 2017 06:11

	const p = source.publishReplay(1);
	p.subscribe(observer("a"));
	p.connect();
	p.subscribe(observer("b"));
	setTimeout(() => p.subscribe(observer("c")), 10);