/
githubmirror
/
next.js
Обзор
Документация
Войти
/
githubmirror
/
next.js
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
canary
test/e2e/cancel-request/readable.ts
31 строка
658 B
Justin Ridgewell
Reimplement stream cancellation (#52281)
26 июл 2023, 22:57
Не верифицирован
26 июл 2023, 22:57
31d2b72
Код
Авторство
О чём код?
import * as stream from 'stream' import { Deferred, sleep } from './sleep' export function Readable(write: number) { const encoder = new TextEncoder() const cleanedUp = new Deferred() const aborted = new Deferred() let i = 0 const readable = { finished: Promise.all([cleanedUp.promise, aborted.promise]).then(() => i), abort() { aborted.resolve() }, stream: new stream.Readable({ async read() { if (i >= write) { return } await sleep(100) this.push(encoder.encode(String(i++))) }, destroy() { cleanedUp.resolve() }, }), } return readable }