tweak

src/chart/helper/LineDraw.js

@@ -217,6 +217,10 @@ function setLargeLineCommon(lineDraw, lineData, seriesScope) {
         seriesModel.getModel('lineStyle.normal').getLineStyle()
     );
 
+    // ???! do it in echarts.js ?
+    var blendMode = seriesModel.get('blendMode') || null;
+    largeLine.style.blend = blendMode;
+
     var visualColor = lineData.getVisual('color');
     if (visualColor) {
         largeLine.setStyle('stroke', visualColor);

src/data/List.js

@@ -108,6 +108,7 @@ DefaultDataProvider.prototype.addData = function (newData) {
 
     var thisArray = this._array;
     if (chunkSize == null) {
+        // ??? performance
         thisArray.push.apply(thisArray, newData);
     }
     else if (chunkSize === newData.length) {

src/echarts.js

@@ -972,22 +972,22 @@ echartsProto.resize = function (opts) {
     var optionChanged = this._model && this._model.resetOption('media');
     var updateMethod = optionChanged ? 'prepareAndUpdate' : 'update';
 
-    refresh(updateMethod, opts && opts.silent);
+    refresh(this, updateMethod, opts && opts.silent);
 };
 
-function refresh(updateMethod, silent) {
-    this[IN_MAIN_PROCESS] = true;
+function refresh(ecIns, updateMethod, silent) {
+    ecIns[IN_MAIN_PROCESS] = true;
 
-    updateMethods[updateMethod].call(this);
+    updateMethods[updateMethod].call(ecIns);
 
     // Resize loading effect
-    this._loadingFX && this._loadingFX.resize();
+    ecIns._loadingFX && ecIns._loadingFX.resize();
 
-    this[IN_MAIN_PROCESS] = false;
+    ecIns[IN_MAIN_PROCESS] = false;
 
-    flushPendingActions.call(this, silent);
+    flushPendingActions.call(ecIns, silent);
 
-    triggerUpdatedEvent.call(this, silent);
+    triggerUpdatedEvent.call(ecIns, silent);
 }
 
 /**

src/stream/task.js

@@ -105,6 +105,14 @@ taskProto.progress = function (params) {
     }, this._progressNotify);
 };
 
+taskProto.getProgressInfo = function () {
+    var fields = inner(this);
+    return {
+        dueIndex: fields.dueIndex,
+        dueEnd: fields.dueEnd
+    };
+};
+
 function progressNotify(dueIndex, outputDueEnd) {
     var fields = inner(this);
 

test/lines-stream-ny.html

@@ -83,7 +83,7 @@
                         // }
 
                         chart.setOption({
-                            streamStep: 4000,
+                            streamStep: 14000,
                             animation: false,
                             geo: {
                                 center: [-74.04327099998152, 40.86737600240287],
@@ -122,8 +122,8 @@
                                 lineStyle: {
                                     normal: {
                                         color: 'purple',
-                                        opacity: 0.4,
-                                        width: 1
+                                        opacity: 1,
+                                        width: 0.5
                                     }
                                 },
                                 stream: config.streamRender ? config.streamThreshold : false