From d8546b317e9907f7de741b6d415789dfd2538010 Mon Sep 17 00:00:00 2001
From: Olivier Lange <olange@petit-atelier.ch>
Date: Mon, 11 Feb 2019 21:00:45 +0100
Subject: [PATCH] Adds first example for RxJS (#1)

---
 experiments/01-rxjs-intro/index.js          | 16 +++++++++++++
 experiments/01-rxjs-intro/package-lock.json | 21 +++++++++++++++++
 experiments/01-rxjs-intro/package.json      | 25 +++++++++++++++++++++
 3 files changed, 62 insertions(+)
 create mode 100644 experiments/01-rxjs-intro/index.js
 create mode 100644 experiments/01-rxjs-intro/package-lock.json
 create mode 100644 experiments/01-rxjs-intro/package.json

diff --git a/experiments/01-rxjs-intro/index.js b/experiments/01-rxjs-intro/index.js
new file mode 100644
index 0000000..d55da2d
--- /dev/null
+++ b/experiments/01-rxjs-intro/index.js
@@ -0,0 +1,16 @@
+const { Observable } = require( "rxjs");
+
+const foo = new Observable(subscriber => {
+  console.log('Hello');
+  subscriber.next(42);
+  subscriber.next(43);
+  setTimeout( () => { subscriber.next(45) }, 1000);
+});
+
+foo.subscribe(x => {
+  console.log(x);
+});
+
+foo.subscribe(y => {
+  console.log(y);
+});
\ No newline at end of file
diff --git a/experiments/01-rxjs-intro/package-lock.json b/experiments/01-rxjs-intro/package-lock.json
new file mode 100644
index 0000000..dd2bc11
--- /dev/null
+++ b/experiments/01-rxjs-intro/package-lock.json
@@ -0,0 +1,21 @@
+{
+  "name": "01-rxjs-intro",
+  "version": "1.0.0",
+  "lockfileVersion": 1,
+  "requires": true,
+  "dependencies": {
+    "rxjs": {
+      "version": "6.4.0",
+      "resolved": "https://registry.npmjs.org/rxjs/-/rxjs-6.4.0.tgz",
+      "integrity": "sha512-Z9Yfa11F6B9Sg/BK9MnqnQ+aQYicPLtilXBp2yUtDt2JRCE0h26d33EnfO3ZxoNxG0T92OUucP3Ct7cpfkdFfw==",
+      "requires": {
+        "tslib": "^1.9.0"
+      }
+    },
+    "tslib": {
+      "version": "1.9.3",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-1.9.3.tgz",
+      "integrity": "sha512-4krF8scpejhaOgqzBEcGM7yDIEfi0/8+8zDRZhNZZ2kjmHJ4hv3zCbQWxoJGz1iw5U0Jl0nma13xzHXcncMavQ=="
+    }
+  }
+}
diff --git a/experiments/01-rxjs-intro/package.json b/experiments/01-rxjs-intro/package.json
new file mode 100644
index 0000000..ff06bd5
--- /dev/null
+++ b/experiments/01-rxjs-intro/package.json
@@ -0,0 +1,25 @@
+{
+  "name": "01-rxjs-intro",
+  "version": "1.0.0",
+  "description": "First steps with RxJS",
+  "main": "index.js",
+  "scripts": {
+    "start": "node index.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/olange/learning-streams/experiments/01-rxjs-intro"
+  },
+  "keywords": [
+    "streams",
+    "observable",
+    "rxjs",
+    "experiment"
+  ],
+  "author": "Olivier Lange",
+  "license": "BSD-3-Clause",
+  "dependencies": {
+    "rxjs": "^6.4.0"
+  }
+}