(onClose?: () => void)
| 21 | ) |
| 22 | |
| 23 | const makeTestConn = (onClose?: () => void): Deno.Conn => { |
| 24 | const transform = new TransformStream<Uint8Array>() |
| 25 | return { |
| 26 | readable: transform.readable, |
| 27 | writable: transform.writable, |
| 28 | read: () => Promise.resolve(null), |
| 29 | write: (data) => Promise.resolve(data.length), |
| 30 | close() { |
| 31 | onClose?.() |
| 32 | }, |
| 33 | closeWrite: () => Promise.resolve(), |
| 34 | ref() {}, |
| 35 | unref() {}, |
| 36 | localAddr: { transport: "tcp", hostname: "127.0.0.1", port: 1 }, |
| 37 | remoteAddr: { transport: "tcp", hostname: "127.0.0.1", port: 2 }, |
| 38 | [Symbol.dispose]() {} |
| 39 | } |
| 40 | } |
| 41 | |
| 42 | const makeTestListener = ( |
| 43 | accepts: ReadonlyArray<() => Promise<Deno.Conn>>, |
no outgoing calls
no test coverage detected