2c:null 2d:["$","title",null,{"children":"Async (Primitives) Benchmark | rix | Observable"}] 32:T4ec,async function measureGrowth(benchmarks, fixatedParams, variableParam, variableMin, variableMax, variableStep) { const results = []; for (const [benchmarkName, benchmarkFn] of Object.entries(benchmarks)) { for (let variableValue = variableMin; variableValue <= variableMax; variableValue += variableStep) { const params = { ...fixatedParams, [variableParam]: variableValue }; const { repeat, depth, breadth } = params; const time = await benchmarkFn(repeat, depth, breadth); results.push({ x: variableValue, y: time, benchmarkName }); } } return Plot.plot({ height: 600, caption: html`Fixated ${Object.entries(fixatedParams).filter(([name]) => name != variableParam).map(([name, val]) => `${name} = ${val}`).join(', ')}, varying ${variableParam} from ${variableMin} to ${variableMax} at steps of ${variableStep}`, style: "overflow: visible;", x: {label: variableParam}, y: {grid: true, label: "time (ms)"}, marks: [ Plot.ruleY([0]), Plot.lineY(results, { x: "x", y: "y", stroke: "benchmarkName" }), Plot.text(results, Plot.selectLast({ x: "x", y: "y", z: "benchmarkName", text: "benchmarkName", textAnchor: "start", dx: 3 })), ] }); }33:T528,async function benchmarkES5Effection(repeat, depth, breadth) { for (let i = 0; i < warmupRepeat; i++) { await run(); } performance.mark('ES5Effection-start'); for (let i = 0; i < repeat; i++) { await run() } return performance.measure('ES5Effection', 'ES5Effection-start').duration; function run() { return ES5Effection.run(() => recurse(depth)); } var _marked = /*#__PURE__*/regeneratorRuntime.mark(recurse); function recurse(depth) { var i; return regeneratorRuntime.wrap(function recurse$(_context) { while (1) { switch (_context.prev = _context.next) { case 0: if (!(depth > 1)) { _context.next = 4; break; } return _context.delegateYield(recurse(depth - 1), "t0", 2); case 2: _context.next = 10; break; case 4: i = 0; case 5: if (!(i < breadth)) { _context.next = 10; break; } return _context.delegateYield(ES5Effection.call(Promise.resolve()), "t1", 7); case 7: i++; _context.next = 5; break; case 10: case "end": return _context.stop(); } } }, _marked); } }34:Tdb0,SimplifiedEffection = (() => { function run(block) { let resolve; let reject; const promise = new Promise((r,j)=>(resolve = r, reject = j)); const stack = [new Run(block,resolve,reject)]; evaluate(stack); return promise; } function *call(promise) { return yield{ type: Instruction.Type.Await, promise }; } function evaluate(stack) { let running = true; try { while (stack.length) { const thunk = stack.pop(); if (thunk instanceof Run) { const {block, resolve, reject} = thunk; let iterator; try { iterator = block()[Symbol.iterator](); } catch (err) { reject(err); } stack.push(new Resume(new Routine(iterator,resolve,reject))); } else if (thunk instanceof Resume) { const {routine, result} = thunk; const {iterator, resolve, reject} = routine; try { const _result = !result ? iterator.next() : result.ok ? iterator.next(result.value) : iterator.throw(result.err); if (_result.done) { resolve(_result.value); } else { const inst = _result.value; switch (inst.type) { case Instruction.Type.Await: { const {promise} = inst; promise.then(function onResolve(value) { stack.push(new Resume(routine,Ok(value))); if (!running) { evaluate(stack); } }, function onReject(err) { stack.push(new Resume(routine,Err(err))); if (!running) { evaluate(stack); } }); break; } } } } catch (err) { reject(err); } } } } finally { running = false; } } class Run { constructor(block, resolve, reject) { this.block = block; this.resolve = resolve; this.reject = reject; } } class Resume { constructor(routine, result) { this.routine = routine; this.result = result; } } class Routine { constructor(iterator, resolve, reject, parent) { this.iterator = iterator; this.resolve = resolve; this.reject = reject; this.parent = parent; } } var Instruction; ((Instruction2)=>{ let Type; ((Type2)=>{ Type2[Type2["Await"] = 0] = "Await"; } )(Type = Instruction2.Type || (Instruction2.Type = {})); } )(Instruction || (Instruction = {})); function Ok(value) { return { ok: true, value }; } function Err(err) { return { ok: false, err }; } return { run, call }; })()35:T11eb,ES5Effection = { function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); Object.defineProperty(Constructor, "prototype", { writable: false }); return Constructor; } function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } var _marked = /*#__PURE__*/regeneratorRuntime.mark(call); function run(block) { var resolve; var reject; var promise = new Promise(function (r, j) { return resolve = r, reject = j; }); var stack = [new Run(block, resolve, reject)]; evaluate(stack); return promise; } function call(promise) { return regeneratorRuntime.wrap(function call$(_context) { while (1) { switch (_context.prev = _context.next) { case 0: _context.next = 2; return { type: Instruction.Type.Await, promise }; case 2: return _context.abrupt("return", _context.sent); case 3: case "end": return _context.stop(); } } }, _marked); } function evaluate(stack) { var running = true; try { while (stack.length) { var thunk = stack.pop(); if (thunk instanceof Run) { var { block, resolve, reject } = thunk; var iterator = void 0; try { iterator = block()[Symbol.iterator](); } catch (err) { reject(err); } stack.push(new Resume(new Routine(iterator, resolve, reject))); } else if (thunk instanceof Resume) { (function () { var { routine, result } = thunk; var { iterator, resolve, reject } = routine; try { var _result = !result ? iterator.next() : result.ok ? iterator.next(result.value) : iterator.throw(result.err); if (_result.done) { resolve(_result.value); } else { var inst = _result.value; switch (inst.type) { case Instruction.Type.Await: { var { promise } = inst; promise.then(function onResolve(value) { stack.push(new Resume(routine, Ok(value))); if (!running) { evaluate(stack); } }, function onReject(err) { stack.push(new Resume(routine, Err(err))); if (!running) { evaluate(stack); } }); break; } } } } catch (err) { reject(err); } })(); } } } finally { running = false; } } var Run = /*#__PURE__*/_createClass(function Run(block, resolve, reject) { _classCallCheck(this, Run); this.block = block; this.resolve = resolve; this.reject = reject; }); var Resume = /*#__PURE__*/_createClass(function Resume(routine, result) { _classCallCheck(this, Resume); this.routine = routine; this.result = result; }); var Routine = /*#__PURE__*/_createClass(function Routine(iterator, resolve, reject, parent) { _classCallCheck(this, Routine); this.iterator = iterator; this.resolve = resolve; this.reject = reject; this.parent = parent; }); var Instruction; (function (Instruction2) { var Type; (function (Type2) { Type2[Type2["Await"] = 0] = "Await"; })(Type = Instruction2.Type || (Instruction2.Type = {})); })(Instruction || (Instruction = {})); function Ok(value) { return { ok: true, value }; } function Err(err) { return { ok: false, err }; } return { run, call }; }36:[] 30:{"id":"09935e9cf17a34d7","slug":"async-primitives-benchmark","title":"Async (Primitives) Benchmark","thumbnail":"f211a8468040ae831c6df570d431fe90c9f7b2861e2752b0fcde9d89d02c9680","access_level":"unlisted","create_time":"$D2024-04-13T16:55:01.704Z","update_time":"$D2026-03-02T22:00:08.440Z","view_time":null,"first_public_time":null,"has_unpublished_edits":null,"fork":true,"stars":0,"starred":false,"owner":{"type":"team","id":"72e51317eb10aec3","login":"rix","name":"rix","avatar_url":"https://avatars-next.observableusercontent.com/20058f5572c00c2807c8c0a31d6dc913ee57ddabc4e75869a4666632e88b7fa3","tier":"starter_2024","bio":""},"version":196,"publish_version":null,"role":null,"authored":false,"authors":[{"type":"individual","id":"ddedbb681d4376e1","login":"rix","name":"rix","avatar_url":"https://avatars-next.observableusercontent.com/20058f5572c00c2807c8c0a31d6dc913ee57ddabc4e75869a4666632e88b7fa3","tier":null,"bio":""}],"members":[{"type":"individual","id":"ddedbb681d4376e1","login":"rix","name":"rix","avatar_url":"https://avatars-next.observableusercontent.com/20058f5572c00c2807c8c0a31d6dc913ee57ddabc4e75869a4666632e88b7fa3","tier":null,"role":"editor"},{"type":"team","id":"72e51317eb10aec3","login":"rix","name":"rix","avatar_url":"https://avatars-next.observableusercontent.com/20058f5572c00c2807c8c0a31d6dc913ee57ddabc4e75869a4666632e88b7fa3","tier":"starter_2024","role":"viewer"}],"comments":[],"custom_thumbnail":false,"trashed":false,"lapsed":null,"subscribed":null,"forks":0,"collection":null,"type":"notebook","body":{"titling":"auto","title":"Async (Primitives) Benchmark","cells":[{"id":0,"value":"# Async (Primitives) Benchmark","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":105,"value":"depthGrowth = {\n return measureGrowth(\n benchmarks,\n { repeat: 10, breadth: 100 },\n 'depth', 1, 1000, 5\n );\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":25,"value":"$32","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":88,"value":"benchmarks = ({\n 'callbacks (RxJS)': benchmarkRxJS,\n 'yield (co.js)': benchmarkCoJS,\n 'async+await': benchmarkAsyncAwait,\n 'ES6 yield*': benchmarkES5Effection,\n 'ES5 yield* (Regenerator)': benchmarkSimplifiedEffection,\n})","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":22,"value":"async function benchmarkEffection(repeat, depth, breadth) {\n for (let i = 0; i < warmupRepeat; i++) {\n await run();\n }\n performance.mark('Effection-start');\n for (let i = 0; i < repeat; i++) {\n await run();\n }\n return performance.measure('Effection', 'Effection-start').duration;\n function run() {\n return Effection.run(() => recurse(depth));\n }\n function* recurse(depth) {\n if (depth > 1) {\n yield* recurse(depth - 1);\n } else {\n for (let i = 0; i < breadth; i++) {\n yield* Effection.call(Promise.resolve());\n }\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":153,"value":"$33","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":20,"value":"async function benchmarkSimplifiedEffection(repeat, depth, breadth) {\n for (let i = 0; i < warmupRepeat; i++) {\n await run();\n }\n performance.mark('SimplifiedEffection-start');\n for (let i = 0; i < repeat; i++) {\n await run()\n }\n return performance.measure('SimplifiedEffection', 'SimplifiedEffection-start').duration;\n function run() {\n return SimplifiedEffection.run(() => recurse(depth));\n }\n function* recurse(depth) {\n if (depth > 1) {\n yield* recurse(depth - 1);\n } else {\n for (let i = 0; i < breadth; i++) {\n yield* SimplifiedEffection.call(Promise.resolve());\n }\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":17,"value":"async function benchmarkRxJS(repeat, depth, breadth) {\n for (let i = 0; i < warmupRepeat; i++) {\n await run();\n }\n performance.mark('RxJS-start');\n for (let i = 0; i < repeat; i++) {\n await run();\n }\n return performance.measure('RxJS', 'RxJS-start').duration;\n function run() {\n return new Promise((resolve) => {\n recurse(depth).subscribe({\n complete() {\n resolve();\n },\n });\n });\n }\n function recurse(depth) {\n return new RxJS.Observable((subscriber) => {\n if (depth > 1) {\n subscriber.add(\n recurse(depth - 1).subscribe({\n complete() {\n subscriber.complete();\n },\n })\n );\n } else {\n subscriber.add(\n RxJS.defer(() => RxJS.from(Promise.resolve()))\n .pipe(RxJS.repeat(breadth))\n .subscribe({\n complete() {\n subscriber.complete();\n },\n })\n );\n }\n });\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":64,"value":"async function benchmarkCoJS(repeat, depth, breadth) {\n for (let i = 0; i < warmupRepeat; i++) {\n await run();\n }\n performance.mark('CoJS-start');\n for (let i = 0; i < repeat; i++) {\n await run()\n }\n return performance.measure('CoJS', 'CoJS-start').duration;\n function run() {\n return co(recurse, depth);\n }\n function* recurse(depth) {\n if (depth > 1) {\n yield recurse(depth - 1);\n } else {\n for (let i = 0; i < breadth; i++) {\n yield Promise.resolve();\n }\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":81,"value":"async function benchmarkAsyncAwait(repeat, depth, breadth) {\n for (let i = 0; i < warmupRepeat; i++) {\n await run();\n }\n performance.mark('AsyncAwait-start');\n for (let i = 0; i < repeat; i++) {\n await run()\n }\n return performance.measure('AsyncAwait', 'AsyncAwait-start').duration;\n async function run() {\n await recurse(depth);\n }\n async function recurse(depth) {\n if (depth > 1) {\n await recurse(depth - 1);\n } else {\n for (let i = 0; i < breadth; i++) {\n await Promise.resolve();\n }\n }\n }\n}","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":14,"value":"warmupRepeat = 10","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":11,"value":"$34","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":149,"value":"$35","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":7,"value":"Effection = import(\"effection@3.0.3\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":5,"value":"RxJS = import(\"rxjs@7.8.1\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":41,"value":"co = require('co@4.6.0').catch(() => window[\"co\"])","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":147,"value":"regeneratorRuntime = require('regenerator-runtime@0.14.1').catch(() => window[\"regeneratorRuntime\"]);","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W36","stdlib":"1"}} 31:"$30:body"