(payload)
| 73 | * gRPC mode: uncompressed gRPC frame. |
| 74 | */ |
| 75 | export function grpcFrame(payload) { |
| 76 | const buf = Buffer.isBuffer(payload) ? payload : Buffer.from(payload); |
| 77 | if (USE_CONNECT) return wrapRequest(buf); |
| 78 | const frame = Buffer.alloc(5 + buf.length); |
| 79 | frame[0] = 0; |
| 80 | frame.writeUInt32BE(buf.length, 1); |
| 81 | buf.copy(frame, 5); |
| 82 | return frame; |
| 83 | } |
| 84 | |
| 85 | /** |
| 86 | * Strip gRPC frame header (5 bytes) from a response buffer. |
no test coverage detected