Method WriteResponseChunk

crawler/rpc/request/rpc_method.go:284–291

(code ResponseCode, data codec.Serializable)

}

func (h *chReqHandler) WriteResponseChunk(code ResponseCode, data codec.Serializable) error {
	h.respBuf.Reset() // re-use buffer for each response chunk
	if err := h.m.ResponseChunkCodec.Encode(&h.respBuf, data); err != nil {
		return err
	}
	b := h.respBuf.Bytes()
	return StreamChunk(code, uint64(len(b)), bytes.NewReader(b), h.w, h.comp)
}

func (h *chReqHandler) WriteRawResponseChunk(code ResponseCode, chunk []byte) error {
	return StreamChunk(code, uint64(len(chunk)), bytes.NewReader(chunk), h.w, h.comp)