From 2aa38ac4b44c21bd3a26de90fa23beb8ffbb6f27 Mon Sep 17 00:00:00 2001
From: kumavis <aaron@kumavis.me>
Date: Sat, 30 Jan 2016 23:14:58 -0800
Subject: util - stream-provider - fix batch

---
 app/scripts/lib/stream-provider.js | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

(limited to 'app/scripts/lib/stream-provider.js')

diff --git a/app/scripts/lib/stream-provider.js b/app/scripts/lib/stream-provider.js
index 5a77979ee..8390cab8a 100644
--- a/app/scripts/lib/stream-provider.js
+++ b/app/scripts/lib/stream-provider.js
@@ -22,7 +22,11 @@ StreamProvider.prototype.send = function(payload){
 
 StreamProvider.prototype.sendAsync = function(payload, callback){
   // console.log('StreamProvider - sending payload', payload)
-  this._payloads[payload.id] = [payload, callback]
+  var id = payload.id
+  if (Array.isArray(payload)) {
+    id = 'batch'+payload[0].id
+  }
+  this._payloads[id] = [payload, callback]
   // console.log('payload for plugin:', payload)
   this.push(payload)
 }
@@ -31,9 +35,13 @@ StreamProvider.prototype.sendAsync = function(payload, callback){
 
 StreamProvider.prototype._onResponse = function(response){
   // console.log('StreamProvider - got response', payload)
-  var data = this._payloads[response.id]
+  var id = response.id
+  if (Array.isArray(response)) {
+    id = 'batch'+response[0].id
+  }
+  var data = this._payloads[id]
   if (!data) throw new Error('StreamProvider - Unknown response id')
-  delete this._payloads[response.id]
+  delete this._payloads[id]
   var payload = data[0]
   var callback = data[1]
 
-- 
cgit