Michał Šrajer michals

Observable Extensions - przydatne rozszerzenia do pracy z RxJava

by Grzegorz Dyrda

1. Współdzielenie strumieni

W RxJava wszystkie strumienie są domyślnie "zimne" - czyli każda nowa subskrypcja powoduje skutki uboczne w źródle. Niestety, takie podejście sprawdza się jedynie w prostych "książkowych" przypadkach. Na co dzień, kiedy tworzymy logikę biznesową za pomocą łączenia/kombinacji strumieni, właściwość ta jest strasznie upierdliwa.

	<!DOCTYPE html>

	<html>
	<head>
	<meta charset="utf-8">
	<meta name="viewport" content="width=device-width, initial-scale=1.0">
	<title>ulam-spiral</title>
	<script type="application/dart" src="main.dart"></script>
	</head>

	All codes are in hexadecimal NEC format, 32 bits long. Ready to use with IRLib Arduino library.

	### DISCRETE INPUTS ###

	Tuner 20DF6B94

	HDMI1 20DF738C
	HDMI2 20DF33CC
	HDMI3 20DF9768
	HDMI4 20DF5BA4

	/* bling.js */
	window.$ = document.querySelector.bind(document);
	window.$$ = document.querySelectorAll.bind(document);
	Node.prototype.on = window.on = function(name, fn) { this.addEventListener(name, fn); };
	NodeList.prototype.__proto__ = Array.prototype;
	NodeList.prototype.on = function(name, fn) { this.forEach((elem) => elem.on(name, fn)); };