From 2663596342fca25e051b58dd8ba42071278eb731 Mon Sep 17 00:00:00 2001 From: Ryan Dahl Date: Thu, 16 May 2019 13:56:57 -0400 Subject: [PATCH] fix --- http/server_test.ts | 33 +++++++-------------------------- 1 file changed, 7 insertions(+), 26 deletions(-) diff --git a/http/server_test.ts b/http/server_test.ts index 82a368395e0d1..904a667c7f9da 100644 --- a/http/server_test.ts +++ b/http/server_test.ts @@ -11,6 +11,7 @@ import { assertEquals } from "../testing/asserts.ts"; import { Response, ServerRequest, writeResponse } from "./server.ts"; import { BufReader, BufWriter } from "../io/bufio.ts"; import { StringReader } from "../io/readers.ts"; +import { deferred } from "../util/async.ts"; interface ResponseTest { response: Response; @@ -22,31 +23,6 @@ const dec = new TextDecoder(); type Handler = () => void; -interface Deferred { - promise: Promise<{}>; - resolve: Handler; - reject: Handler; -} - -function deferred(isResolved = false): Deferred { - let resolve: Handler = (): void => void 0; - let reject: Handler = (): void => void 0; - const promise = new Promise( - (res, rej): void => { - resolve = res; - reject = rej; - } - ); - if (isResolved) { - resolve(); - } - return { - promise, - resolve, - reject - }; -} - const responseTests: ResponseTest[] = [ // Default response { @@ -74,6 +50,11 @@ test(async function responseWrite(): Promise { const request = new ServerRequest(); request.pipelineId = 1; request.w = bufw; + + const d0 = deferred(); + d0.resolve(); + const d1 = deferred(); + request.conn = { localAddr: "", remoteAddr: "", @@ -88,7 +69,7 @@ test(async function responseWrite(): Promise { }, close: (): void => {}, lastPipelineId: 0, - pendingDeferredMap: new Map([[0, deferred(true)], [1, deferred()]]) + pendingDeferredMap: new Map([[0, d0], [1, d1]]) }; await request.respond(testCase.response);