rm

Author: jph00

fastcore/_nbdev.py

@@ -164,7 +164,6 @@
          "spark_chars": "03_xtras.ipynb",
          "sparkline": "03_xtras.ipynb",
          "autostart": "03_xtras.ipynb",
-         "time_events": "03_xtras.ipynb",
          "EventTimer": "03_xtras.ipynb",
          "stringfmt_names": "03_xtras.ipynb",
          "PartialFormatter": "03_xtras.ipynb",

fastcore/xtras.py

@@ -2,9 +2,9 @@
 
 __all__ = ['dict2obj', 'obj2dict', 'repr_dict', 'is_listy', 'shufflish', 'mapped', 'IterLen', 'ReindexCollection',
            'maybe_open', 'image_size', 'bunzip', 'join_path_file', 'loads', 'untar_dir', 'repo_details', 'run',
-           'open_file', 'save_pickle', 'load_pickle', 'truncstr', 'spark_chars', 'sparkline', 'autostart',
-           'time_events', 'EventTimer', 'stringfmt_names', 'PartialFormatter', 'partial_format', 'utc2local',
-           'local2utc', 'trace', 'round_multiple', 'modified_env', 'ContextManagers', 'str2bool', 'sort_by_run']
+           'open_file', 'save_pickle', 'load_pickle', 'truncstr', 'spark_chars', 'sparkline', 'autostart', 'EventTimer',
+           'stringfmt_names', 'PartialFormatter', 'partial_format', 'utc2local', 'local2utc', 'trace', 'round_multiple',
+           'modified_env', 'ContextManagers', 'str2bool', 'sort_by_run']
 
 # Cell
 from .imports import *
@@ -253,13 +253,6 @@ def f():
         return r
     return f
 
-# Cell
-@autostart
-def time_events():
-    "An event timer implemented as a coroutine"
-    start,events = default_timer(),0
-    while True: events += (yield events,events/(default_timer()-start)) or 0
-
 # Cell
 class EventTimer:
     "An event timer with history of `store` items of time `span`"

nbs/03_xtras.ipynb

@@ -618,7 +618,7 @@
     {
      "data": {
       "text/plain": [
-       "['a', 'e', 'h', 'b', 'g', 'd', 'c', 'f']"
+       "['a', 'f', 'b', 'g', 'd', 'e', 'h', 'c']"
       ]
      },
      "execution_count": null,
@@ -1421,58 +1421,6 @@
     "    return f"
    ]
   },
-  {
-   "cell_type": "code",
-   "execution_count": null,
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "#export\n",
-    "@autostart\n",
-    "def time_events():\n",
-    "    \"An event timer implemented as a coroutine\"\n",
-    "    start,events = default_timer(),0\n",
-    "    while True: events += (yield events,events/(default_timer()-start)) or 0"
-   ]
-  },
-  {
-   "cell_type": "markdown",
-   "metadata": {},
-   "source": [
-    "This is convenient for tracking the frequency of events. Call `send(n)` any time you want to add `n` events to the counter. Pass the object to `next()` to get a tuple of the number of events and the frequency/second."
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": null,
-   "metadata": {},
-   "outputs": [],
-   "source": [
-    "# Random wait function for testing `time_events`\n",
-    "def _randwait(): yield from (sleep(random.random()/200) for _ in range(100))"
-   ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": null,
-   "metadata": {},
-   "outputs": [
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "# Events: 100, Freq/sec: 396.51\n"
-     ]
-    }
-   ],
-   "source": [
-    "c = time_events()                # Start timer\n",
-    "for o in _randwait(): c.send(1)  # Send an event\n",
-    "events,freq = next(c)            # Return counter values\n",
-    "c.close()                        # Close when done\n",
-    "print(f'# Events: {events}, Freq/sec: {freq:.02f}')"
-   ]
-  },
   {
    "cell_type": "code",
    "execution_count": null,
@@ -1544,12 +1492,15 @@
      "name": "stdout",
      "output_type": "stream",
      "text": [
-      "Num Events: 5, Freq/sec: 646.7\n",
-      "Most recent:  ▁▇▃▇▆ 259.5 450.4 362.1 441.0 427.9\n"
+      "Num Events: 1, Freq/sec: 225.7\n",
+      "Most recent:  ▇▁▁▁▁ 346.2 331.6 334.4 332.2 332.9\n"
      ]
     }
    ],
    "source": [
+    "# Random wait function for testing\n",
+    "def _randwait(): yield from (sleep(random.random()/200) for _ in range(100))\n",
+    "\n",
     "c = EventTimer(store=5, span=0.03)\n",
     "for o in _randwait(): c.add(1)\n",
     "print(f'Num Events: {c.events}, Freq/sec: {c.freq:.01f}')\n",