Function StreamChunk

crawler/rpc/request/encode.go:117–122

StreamChunk reads (decompressed) response message from the msg io.Reader, and writes it as a chunk with given result code to the output writer. The compression is optional and may be nil.

(result ResponseCode, size uint64, r io.Reader, w io.Writer, comp Compression)

// StreamChunk reads (decompressed) response message from the msg io.Reader,
// and writes it as a chunk with given result code to the output writer. The compression is optional and may be nil.
func StreamChunk(result ResponseCode, size uint64, r io.Reader, w io.Writer, comp Compression) error {
	if err := EncodeResult(result, w); err != nil {
		return err
	}
	return StreamHeaderAndPayload(size, r, w, comp)
}