(promise, destination, pipeFailureSignal)
| 107 | }; |
| 108 | |
| 109 | const forwardIpcMethods = (promise, destination, pipeFailureSignal) => { |
| 110 | promise.sendMessage = destination.sendMessage; |
| 111 | promise.getOneMessage = getOnePipeMessage.bind(undefined, destination, pipeFailureSignal); |
| 112 | promise.getEachMessage = getEachPipeMessage.bind(undefined, promise, destination, pipeFailureSignal); |
| 113 | }; |
| 114 | |
| 115 | const getOnePipeMessage = (destination, pipeFailureSignal, ...arguments_) => { |
| 116 | const controller = new AbortController(); |
no outgoing calls
no test coverage detected