Lars Gyrup Brink Nielsen LayZeeDK

🇩🇰

Denmark

Microsoft MVP, Nx Champion, Co-Founder of This is Learning, Organizer of AarhusJS, Author, Writer, Speaker, Open-Source Maintainer.

LayZeeDK / medium-rxjs-ref-count-resubscribe-no-complete.ts

Last active July 20, 2019 22:54 — forked from cartant/medium-rxjs-ref-count-resubscribe-no-complete.ts

RxJS ≥6 version

	const source = instrument(interval(100));
	const counted = source.pipe(publish(), refCount());
	const a = counted.subscribe(observer("a"));
	setTimeout(() => a.unsubscribe(), 110);
	setTimeout(() => counted.subscribe(observer("b")), 120);

LayZeeDK / medium-rxjs-ref-count-resubscribe-complete.ts

Last active July 20, 2019 22:51 — forked from cartant/medium-rxjs-ref-count-resubscribe-complete.ts

RxJS ≥6 version

	const source = instrument(timer(100));
	const counted = source.pipe(publish(), refCount());
	const a = counted.subscribe(observer("a"));
	setTimeout(() => a.unsubscribe(), 110);
	setTimeout(() => counted.subscribe(observer("b")), 120);

LayZeeDK / medium-rxjs-ref-count-teardown-ref-count.ts

Last active July 20, 2019 22:50 — forked from cartant/medium-rxjs-ref-count-teardown-ref-count.ts

RxJS ≥6 version

	const source = instrument(interval(100));
	const counted = source.pipe(publish(), refCount());
	const a = counted.pipe(take(1)).subscribe(observer("a"));
	const b = counted.pipe(take(1)).subscribe(observer("b"));

LayZeeDK / medium-rxjs-ref-count-util.ts

Last active July 20, 2019 22:48 — forked from cartant/medium-rxjs-ref-count-util.ts

RxJS ≥6 version

	function instrument<T>(source: Observable<T>) {
	return new Observable<T>(observer => {
	console.log("source: subscribing");
	const subscription = source.pipe(
	tap(value => console.log(`source: ${value}`)),
	).subscribe(observer);
	return () => {
	subscription.unsubscribe();
	console.log("source: unsubscribed");
	};

LayZeeDK / medium-rxjs-ref-count-teardown-connect.ts

Last active July 20, 2019 22:46 — forked from cartant/medium-rxjs-ref-count-teardown-connect.ts

RxJS ≥6 version

	const source = instrument(interval(100));
	const published = source.pipe(publish());
	const a = published.pipe(take(1)).subscribe(observer("a"));
	const b = published.pipe(take(1)).subscribe(observer("b"));
	const subscription = published.connect();

LayZeeDK / medium-rxjs-publish.ts

Last active July 20, 2019 22:29 — forked from cartant/medium-rxjs-publish.ts

	import { concat, defer, Observable, of } from "rxjs";
	import { delay, publish } from "rxjs/operators";

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

	const source = concat(
	defer(() => of(random())),
	defer(() => of(random())).pipe(delay(1))

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

Last active July 20, 2019 22:16 — forked from cartant/medium-rxjs-publish-multicast-delay.ts

RxJS ≥6 version

	import { defer, Observable, of, Subject } from "rxjs";
	import { delay, multicast } from "rxjs/operators";

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

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

Last active July 20, 2019 15:21 — forked from cartant/medium-rxjs-publish-mental-model.ts

RxJS ≥6 version

	import { defer, Observable, of, Subject } from "rxjs";

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

	function observer(name: string) {
	return {
	next: (value: number) => console.log(`observer ${name}: ${value}`),
	complete: () => console.log(`observer ${name}: complete`)

LayZeeDK / medium-rxjs-publish-multicast.ts

Last active July 20, 2019 22:19 — forked from cartant/medium-rxjs-publish-multicast.ts

	import { defer, Observable, of, Subject } from "rxjs";
	import { multicast } from "rxjs/operators";

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

	function observer(name: string) {
	return {
	next: (value: number) => console.log(`observer ${name}: ${value}`),

LayZeeDK / connection.component.ts

Last active October 19, 2018 06:44 — forked from NetanelBasal/connection.component.ts

	import { Component, ContentChild } from '@angular/core';
	import { map } from 'rxjs/operators';

	import { ConnectionService } from './connection.service';
	import { FastDirective} from './fast.directive';
	import { SlowDirective} from './slow.directive';

	@Component({
	selector: 'connection',
	template: `