@travetto/compiler
Advanced tools
Comparing version 4.0.1 to 4.0.2
{ | ||
"name": "@travetto/compiler", | ||
"version": "4.0.1", | ||
"version": "4.0.2", | ||
"description": "The compiler infrastructure for the Travetto framework", | ||
@@ -39,3 +39,3 @@ "keywords": [ | ||
"peerDependencies": { | ||
"@travetto/cli": "^4.0.1" | ||
"@travetto/cli": "^4.0.3" | ||
}, | ||
@@ -42,0 +42,0 @@ "peerDependenciesMeta": { |
import rl from 'node:readline/promises'; | ||
import timers from 'node:timers/promises'; | ||
import { Readable } from 'node:stream'; | ||
import http, { Agent } from 'node:http'; | ||
@@ -113,5 +113,14 @@ import { ManifestContext } from '@travetto/manifest'; | ||
signal.addEventListener('abort', quit); | ||
const stream = await this.#fetch(`/event/${type}`, { signal: ctrl.signal, keepalive: true }); | ||
const res = await new Promise<http.IncomingMessage>(resolve => { | ||
http.get(`${this.#url}/event/${type}`, { | ||
agent: new Agent({ | ||
keepAlive: true, | ||
keepAliveMsecs: 10000, | ||
timeout: 1000 * 60 * 60 * 24 | ||
}), | ||
signal: ctrl.signal | ||
}, res => resolve(res)) | ||
}); | ||
for await (const line of rl.createInterface(Readable.fromWeb(stream.body!))) { | ||
for await (const line of rl.createInterface(res)) { | ||
if (line.trim().charAt(0) === '{') { | ||
@@ -118,0 +127,0 @@ const val = JSON.parse(line); |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
81346
1787