chore: add linebreaks

ReactiveX · Jul 29, 2022 · 7482616 · 7482616
1 parent 19cfab8
commit 7482616
Showing 1 changed file with 27 additions and 25 deletions.
diff --git a/notebooks/reactivex.io/A Decision Tree of Observable Operators. Part I - Creation.ipynb b/notebooks/reactivex.io/A Decision Tree of Observable Operators. Part I - Creation.ipynb
@@ -2,7 +2,7 @@
  "cells": [
   {
    "cell_type": "code",
-   "execution_count": 29,
+   "execution_count": 14,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -11,7 +11,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 30,
+   "execution_count": 15,
    "metadata": {},
    "outputs": [
     {
@@ -96,7 +96,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 31,
+   "execution_count": 17,
    "metadata": {},
    "outputs": [
     {
@@ -114,17 +114,17 @@
       "    Alias for :func:`reactivex.return_value`.\n",
       "--------------------------------------------------------------------------------\n",
       "\n",
-      "   2.0     M New subscription (23900) on stream 276504995\n",
-      "   2.5     M [next]    0.5: {'answer': 595} -> 23900\n",
-      "   2.5     M [cmpl]    0.5: fin -> 23900\n",
+      "   1.8     M New subscription (85706) on stream 273685700\n",
+      "   2.0     M [next]    0.2: {'answer': 131} -> 85706\n",
+      "   2.1     M [cmpl]    0.2: fin -> 85706\n",
       "\n",
-      " 507.8     M New subscription (05073) on stream 276504995\n",
-      " 508.1     M [next]    0.3: {'answer': 595} -> 05073\n",
-      " 508.2     M [cmpl]    0.3: fin -> 05073\n",
+      " 507.5     M New subscription (48150) on stream 273685700\n",
+      " 508.2     M [next]    0.6: {'answer': 131} -> 48150\n",
+      " 508.2     M [cmpl]    0.6: fin -> 48150\n",
       "\n",
-      " 508.5     M New subscription (56710) on stream 276505049\n",
-      " 508.6     M [next]    0.1: 1190 -> 56710\n",
-      " 508.7     M [cmpl]    0.2: fin -> 56710\n"
+      " 508.8     M New subscription (77575) on stream 273648297\n",
+      " 509.0     M [next]    0.2: 262 -> 77575\n",
+      " 509.0     M [cmpl]    0.2: fin -> 77575\n"
      ]
     }
    ],
@@ -252,7 +252,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 33,
+   "execution_count": 18,
    "metadata": {},
    "outputs": [
     {
@@ -291,17 +291,17 @@
       "        given iterable sequence.\n",
       "--------------------------------------------------------------------------------\n",
       "\n",
-      "   2.4     M New subscription (05085) on stream 276505043\n",
-      "   2.6     M [next]    0.2: 1 -> 05085\n",
-      "   2.6     M [next]    0.2: 2 -> 05085\n",
-      "   2.7     M [next]    0.3: 862 -> 05085\n",
-      "   2.7     M [cmpl]    0.3: fin -> 05085\n",
-      "\n",
-      "   3.2     M New subscription (53593) on stream 276612205\n",
-      "   3.4     M [next]    0.1: 813 -> 53593\n",
-      "   3.4     M [next]    0.1: 204 -> 53593\n",
-      "   3.4     M [next]    0.2: 550 -> 53593\n",
-      "   3.4     M [cmpl]    0.2: fin -> 53593\n"
+      "   2.5     M New subscription (13689) on stream 273713890\n",
+      "   2.7     M [next]    0.2: 1 -> 13689\n",
+      "   2.7     M [next]    0.2: 2 -> 13689\n",
+      "   2.7     M [next]    0.2: 608 -> 13689\n",
+      "   2.8     M [cmpl]    0.3: fin -> 13689\n",
+      "\n",
+      "   3.1     M New subscription (77584) on stream 273633238\n",
+      "   3.2     M [next]    0.1: 867 -> 77584\n",
+      "   3.2     M [next]    0.1: 847 -> 77584\n",
+      "   3.3     M [next]    0.2: 486 -> 77584\n",
+      "   3.3     M [cmpl]    0.2: fin -> 77584\n"
      ]
     }
    ],
@@ -406,7 +406,9 @@
    "source": [
     "rst()\n",
     "# start a stream of 0, 1, 2, .. after 200 ms, with a delay of 100 ms:\n",
-    "stream = reactivex.timer(200, 100).pipe(ops.time_interval(), ops.map(lambda x: 'val:%s dt:%s' % (x.value, x.interval)), ops.take(3))\n",
+    "stream = reactivex.timer(200, 100).pipe(ops.time_interval(), \n",
+    "                                        ops.map(lambda x: 'val:%s dt:%s' % (x.value, x.interval)), \n",
+    "                                        ops.take(3))\n",
     "d = subs(stream, name='observer1')\n",
     "# intermix directly with another one\n",
     "d = subs(stream, name='observer2')"