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

Function Ot

out/cli.cjs:7819–7940  ·  view source on GitHub ↗
(e3, t2)

Source from the content-addressed store, hash-verified

7817 });
7818}
7819function Ot(e3, t2) {
7820 return function(e4) {
7821 try {
7822 return e4.getReader({ mode: "byob" }).releaseLock(), true;
7823 } catch (e5) {
7824 return false;
7825 }
7826 }(e3) ? function(e4) {
7827 let t3, r3, o3, n2, a4, i3 = e4.getReader(), l3 = false, s2 = false, d7 = false, f4 = false, h4 = false, p4 = false;
7828 const m5 = u2((e5) => {
7829 a4 = e5;
7830 });
7831 function y6(e5) {
7832 _6(e5.closed, (t4) => (e5 !== i3 || (o3.error(t4), n2.error(t4), h4 && p4 || a4(void 0)), null));
7833 }
7834 function g5() {
7835 l3 && (i3.releaseLock(), i3 = e4.getReader(), y6(i3), l3 = false), b6(i3.read(), (e5) => {
7836 var t4, r4;
7837 if (d7 = false, f4 = false, e5.done) return h4 || o3.close(), p4 || n2.close(), null === (t4 = o3.byobRequest) || void 0 === t4 || t4.respond(0), null === (r4 = n2.byobRequest) || void 0 === r4 || r4.respond(0), h4 && p4 || a4(void 0), null;
7838 const l4 = e5.value, u3 = l4;
7839 let c4 = l4;
7840 if (!h4 && !p4) try {
7841 c4 = le2(l4);
7842 } catch (e6) {
7843 return o3.error(e6), n2.error(e6), a4(i3.cancel(e6)), null;
7844 }
7845 return h4 || o3.enqueue(u3), p4 || n2.enqueue(c4), s2 = false, d7 ? S6() : f4 && v5(), null;
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 1

teeMethod · 0.85

Calls 6

u2Function · 0.85
y6Function · 0.85
_6Function · 0.85
releaseLockMethod · 0.45
getReaderMethod · 0.45
errorMethod · 0.45

Tested by

no test coverage detected