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

Function lazyllhttp

out/cli.cjs:54077–54126  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

54075 [client],
54076 err
54077 );
54078 resume2(client);
54079 }
54080 var constants3 = require_constants4();
54081 var createRedirectInterceptor = require_redirectInterceptor();
54082 var EMPTY_BUF = Buffer.alloc(0);
54083 async function lazyllhttp() {
54084 const llhttpWasmData = process.env.JEST_WORKER_ID ? require_llhttp_wasm() : void 0;
54085 let mod;
54086 try {
54087 mod = await WebAssembly.compile(Buffer.from(require_llhttp_simd_wasm(), "base64"));
54088 } catch (e3) {
54089 mod = await WebAssembly.compile(Buffer.from(llhttpWasmData || require_llhttp_wasm(), "base64"));
54090 }
54091 return await WebAssembly.instantiate(mod, {
54092 env: {
54093 /* eslint-disable camelcase */
54094 wasm_on_url: (p4, at2, len) => {
54095 return 0;
54096 },
54097 wasm_on_status: (p4, at2, len) => {
54098 assert2.strictEqual(currentParser.ptr, p4);
54099 const start = at2 - currentBufferPtr + currentBufferRef.byteOffset;
54100 return currentParser.onStatus(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
54101 },
54102 wasm_on_message_begin: (p4) => {
54103 assert2.strictEqual(currentParser.ptr, p4);
54104 return currentParser.onMessageBegin() || 0;
54105 },
54106 wasm_on_header_field: (p4, at2, len) => {
54107 assert2.strictEqual(currentParser.ptr, p4);
54108 const start = at2 - currentBufferPtr + currentBufferRef.byteOffset;
54109 return currentParser.onHeaderField(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
54110 },
54111 wasm_on_header_value: (p4, at2, len) => {
54112 assert2.strictEqual(currentParser.ptr, p4);
54113 const start = at2 - currentBufferPtr + currentBufferRef.byteOffset;
54114 return currentParser.onHeaderValue(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
54115 },
54116 wasm_on_headers_complete: (p4, statusCode, upgrade, shouldKeepAlive) => {
54117 assert2.strictEqual(currentParser.ptr, p4);
54118 return currentParser.onHeadersComplete(statusCode, Boolean(upgrade), Boolean(shouldKeepAlive)) || 0;
54119 },
54120 wasm_on_body: (p4, at2, len) => {
54121 assert2.strictEqual(currentParser.ptr, p4);
54122 const start = at2 - currentBufferPtr + currentBufferRef.byteOffset;
54123 return currentParser.onBody(new FastBuffer(currentBufferRef.buffer, start, len)) || 0;
54124 },
54125 wasm_on_message_complete: (p4) => {
54126 assert2.strictEqual(currentParser.ptr, p4);
54127 return currentParser.onMessageComplete() || 0;
54128 }
54129 /* eslint-enable camelcase */

Callers 1

Calls 8

onStatusMethod · 0.80
onMessageBeginMethod · 0.80
onHeaderFieldMethod · 0.80
onHeaderValueMethod · 0.80
onHeadersCompleteMethod · 0.80
onBodyMethod · 0.80
onMessageCompleteMethod · 0.80
fromMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…