( id: number, reason: string, invokeFn: typeof invoke = invoke, )
| 8 | * stream terminates). |
| 9 | */ |
| 10 | export function closeWebSocket( |
| 11 | id: number, |
| 12 | reason: string, |
| 13 | invokeFn: typeof invoke = invoke, |
| 14 | ): Promise<void> { |
| 15 | return invokeFn("plugin:websocket|send", { |
| 16 | id, |
| 17 | message: { |
| 18 | type: "Close", |
| 19 | data: { code: 1000, reason }, |
| 20 | }, |
| 21 | }).then( |
| 22 | () => undefined, |
| 23 | (err) => { |
| 24 | // Expected when the socket is already gone; greppable for anything else. |
| 25 | console.debug(`closeWebSocket(${id}, ${reason}) rejected:`, err); |
| 26 | }, |
| 27 | ); |
| 28 | } |
no outgoing calls
no test coverage detected