Method createDataflowService

src/openlayers/mapping/WebMap.js:4139–4152

* @private * @function WebMap.prototype.createDataflowService * @description 将feature添加到数据流图层 * @param {Object} layerInfo - 图层参数 * @param {Object} callback - 回调函数

(layerInfo, callback)

   * @param {Object} callback - 回调函数
   */
  createDataflowService(layerInfo, callback) {
    let that = this;
    let dataflowService = new DataFlowService(layerInfo.wsUrl).initSubscribe();
    dataflowService.on('messageSucceeded', function (e) {
      let geojson = JSON.parse(e.value.data);
      let feature = transformTools.readFeature(geojson, {
        dataProjection: layerInfo.projection || 'EPSG:4326',
        featureProjection: that.baseProjection || 'EPSG:4326'
      });
      feature.setProperties({ attributes: geojson.properties });
      callback(feature);
    });
    layerInfo.dataflowService = dataflowService;
  }

  /**
   * @private