HarmonyOS 鸿蒙Next Http发起的requestInStream流式请求，dataReceiveProgress不执行

HarmonyOS 鸿蒙Next Http发起的requestInStream流式请求，dataReceiveProgress不执行 我发起了一个流式请求。（获取摄像头的数据，后用image显示）

发现订阅走了 headersReceive 和 dataReceive；不走dataEnd和dataReceiveProgress； dataReceive拿到数据后用image.createPixelMap 转出图片，但是出现彩色马赛克。

这个请求在网页请求是可以出现画面的。如图

let streamUrlStr = "http://192.168.0.111:8080/?action=stream";
// 每一个httpRequest对应一个HTTP请求任务，不可复用
let httpRequest = http.createHttp();
// 用于订阅HTTP流式响应数据接收事件
let res = new ArrayBuffer(0);
// 用于订阅HTTP响应头事件
httpRequest.on('headersReceive', (header: Object) => {
  console.info('xx00-header: ' + JSON.stringify(header));
});
httpRequest.on('dataReceive', (data: ArrayBuffer) => {
  const newRes = new ArrayBuffer(res.byteLength + data.byteLength);
  const resView = new Uint8Array(newRes);
  resView.set(new Uint8Array(res));
  resView.set(new Uint8Array(data), res.byteLength);
  res = newRes;
  console.info('XXOO-res length: ' + res.byteLength);

  console.info('xx00-data length: ' + data.byteLength);
  // data 转图片类型 显示出来
  let opts: image.InitializationOptions = {
    // alphaType: 0,
    size: { width: 100, height:50},// 1920 1080
    pixelFormat: image.PixelMapFormat.RGBA_8888,
    // editable: true
  };
  image.createPixelMap(newRes,opts).then((pix)=>{
    this.mainImage = pix;
  }).catch((error: BusinessError) => {
    console.error(`Failed to create pixelmap. code is ${error.code}, message is ${error.message}`);
  });

});
// 用于订阅HTTP流式响应数据接收完毕事件
httpRequest.on('dataEnd', () => {
  console.info('xxoo-No more data in response, data receive end');
});
// 用于订阅HTTP流式响应数据接收进度事件
class Data {
  receiveSize: number = 0;
  totalSize: number = 0;
}
httpRequest.on('dataReceiveProgress', (data: Data) => {
  console.log("xxoo-dataReceiveProgress receiveSize:" + data.receiveSize + ", totalSize:" + data.totalSize);
});

let streamInfo: http.HttpRequestOptions = {
  // 开发者根据自身业务需要添加header字段
  header: {
    'Content-Type': 'application/octet-stream：ArrayBuffer'//'application/json'
  },
  // expectDataType:  http.HttpDataType.STRING,// 可选，指定返回数据的类型
  usingCache: false, // 可选，默认为true
  priority: 1, // 可选，默认为1
  connectTimeout: 60000, // 可选，默认为60000ms
  readTimeout: 60000, // 可选，默认为60000ms。若传输的数据较大，需要较长的时间，建议增大该参数以保证数据传输正常终止
  usingProtocol: http.HttpProtocol.HTTP1_1 // 可选，协议类型默认值由系统自动指定
}

// 填写HTTP请求的URL地址，可以带参数也可以不带参数。URL地址需要开发者自定义。请求的参数可以在extraData中指定
httpRequest.requestInStream(streamUrlStr, streamInfo).then((data: number) => {
  console.info("requestInStream OK!");
  console.info('ResponseCode :' + JSON.stringify(data));
  // 取消订阅HTTP响应头事件
  httpRequest.off('headersReceive');
  // 取消订阅HTTP流式响应数据接收事件
  httpRequest.off('dataReceive');
  // 取消订阅HTTP流式响应数据接收进度事件
  httpRequest.off('dataReceiveProgress');
  // 取消订阅HTTP流式响应数据接收完毕事件
  httpRequest.off('dataEnd');
  // 当该请求使用完毕时，调用destroy方法主动销毁
  httpRequest.destroy();
}).catch((err: Error) => {
  console.info("requestInStream ERROR : err = " + JSON.stringify(err));
});