MCPcopy
hub / github.com/di-sukharev/opencommit / w7

Function w7

out/cli.cjs:7848–7873  ·  view source on GitHub ↗
(t4, r4)

Source from the content-addressed store, hash-verified

7846 }, () => (s2 = false, null));
7847 }
7848 function w7(t4, r4) {
7849 l3 || (i3.releaseLock(), i3 = e4.getReader({ mode: "byob" }), y6(i3), l3 = true);
7850 const u3 = r4 ? n2 : o3, c4 = r4 ? o3 : n2;
7851 b6(i3.read(t4), (e5) => {
7852 var t5;
7853 d7 = false, f4 = false;
7854 const o4 = r4 ? p4 : h4, n3 = r4 ? h4 : p4;
7855 if (e5.done) {
7856 o4 || u3.close(), n3 || c4.close();
7857 const r5 = e5.value;
7858 return void 0 !== r5 && (o4 || u3.byobRequest.respondWithNewView(r5), n3 || null === (t5 = c4.byobRequest) || void 0 === t5 || t5.respond(0)), o4 && n3 || a4(void 0), null;
7859 }
7860 const l4 = e5.value;
7861 if (n3) o4 || u3.byobRequest.respondWithNewView(l4);
7862 else {
7863 let e6;
7864 try {
7865 e6 = le2(l4);
7866 } catch (e7) {
7867 return u3.error(e7), c4.error(e7), a4(i3.cancel(e7)), null;
7868 }
7869 o4 || u3.byobRequest.respondWithNewView(l4), c4.enqueue(e6);
7870 }
7871 return s2 = false, d7 ? S6() : f4 && v5(), null;
7872 }, () => (s2 = false, null));
7873 }
7874 function S6() {
7875 if (s2) return d7 = true, c3(void 0);
7876 s2 = true;

Callers 2

S6Function · 0.85
v5Function · 0.85

Calls 14

y6Function · 0.85
b6Function · 0.85
le2Function · 0.85
S6Function · 0.85
v5Function · 0.85
releaseLockMethod · 0.45
getReaderMethod · 0.45
readMethod · 0.45
closeMethod · 0.45
respondWithNewViewMethod · 0.45
respondMethod · 0.45
errorMethod · 0.45

Tested by

no test coverage detected