MCPcopy
hub / github.com/coder/mux / next

Function next

src/browser/testUtils.ts:68–80  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

66 return iterable;
67 },
68 next() {
69 if (closed) {
70 return Promise.resolve(doneResult());
71 }
72
73 if (buffered.length > 0) {
74 return Promise.resolve({ value: buffered.shift() as T, done: false });
75 }
76
77 return new Promise((resolve) => {
78 pending.push(resolve);
79 });
80 },
81 return() {
82 options.onReturn?.();
83 close();

Callers 3

releaseMethod · 0.50
createAuthMiddlewareFunction · 0.50
createOrpcServerFunction · 0.50

Calls 3

doneResultFunction · 0.85
resolveMethod · 0.80
pushMethod · 0.65

Tested by

no test coverage detected