(channel, req, message, handle)
| 76 | }, |
| 77 | |
| 78 | writeChannelMessage(channel, req, message, handle) { |
| 79 | // Pass the stable Buffer constructor so the native codec can classify Node |
| 80 | // Buffers via `value.constructor === Buffer` without reading the tamperable |
| 81 | // Buffer.prototype.constructor. |
| 82 | const serializedMessage = serialize(message, Buffer); |
| 83 | |
| 84 | const result = channel.writeBuffer(req, serializedMessage, handle); |
| 85 | |
| 86 | // Mirror what stream_base_commons.js does for Buffer retention. |
| 87 | if (streamBaseState[kLastWriteWasAsync]) |
| 88 | req.buffer = serializedMessage; |
| 89 | |
| 90 | return result; |
| 91 | }, |
| 92 | }; |
| 93 | |
| 94 | const json = { |
no test coverage detected
searching dependent graphs…