TIMOB-10162: BlackBerry: Implement Ti.Stream.pump for Anvil

apidoc/Titanium/Stream/Stream.yml

@@ -297,7 +297,7 @@ methods:
         type: Boolean
         optional: true
         default: false
-    platforms: [android, iphone, ipad]
+    platforms: [android, iphone, ipad, blackberry]
 
 ---
 name: CreateStreamArgs
@@ -421,7 +421,7 @@ description: |
     pump operation, either because of an error or because the end of the
     stream has been reached.
 since: "1.7"
-platforms: [android, iphone, ipad]
+platforms: [android, iphone, ipad, blackberry]
 
 properties:
   - name: source

blackberry/tibb/NativeBufferObject.cpp

@@ -191,7 +191,10 @@ int NativeBufferObject::getValue(TiObject* /*obj*/)
 
 void NativeBufferObject::clear()
 {
+    //reset data, but keep size the same
+    int size = internalData_.size();
     internalData_.clear();
+    internalData_.resize(size);
 }
 
 const char* NativeBufferObject::toString() const

blackberry/tibb/NativeTCPSocketObject.cpp

@@ -453,6 +453,10 @@ int NativeTCPSocketObject::read(NativeBufferObject* buffer, int offset, int leng
             bytesRead = readData.size();
         }
     }
+    else
+    {
+        eventHandler_->error(tcpClient_->error());
+    }
 
     return bytesRead;
 }

blackberry/tibb/titanium/javascript/bootstrap.js

@@ -20,3 +20,59 @@ L = function(key, hint)
 Ti.BufferStream.demoFunc = function() {
     Ti.API.debug("demoFunc is being run");
 };
+
+Ti.Stream.pump = function(inputStream, handler, maxChunkSize, isAsync)
+{
+    if (isAsync === undefined)
+    {
+        isAsync = false;
+    }
+    var buffer = Ti.createBuffer({ length: maxChunkSize });
+    var pumpCallBackArgs  = {
+        buffer: buffer,
+        bytesProcessed: -1,
+        errorDescription: '',
+        errorState: 0,
+        source: inputStream,
+        totalBytesProcessed: 0,
+    };
+
+    var readHelper = function() {
+        buffer.clear();
+        pumpCallBackArgs.bytesProcessed = -1;
+        try
+        {
+            pumpCallBackArgs.bytesProcessed = inputStream.read(buffer, 0, maxChunkSize);
+        }
+        catch(err)
+        {
+            pumpCallBackArgs.errorDescription = err;
+            pumpCallBackArgs.errorState = 1;
+        }
+        if (pumpCallBackArgs.bytesProcessed >= 0)
+        {
+            pumpCallBackArgs.totalBytesProcessed += pumpCallBackArgs.bytesProcessed;
+        }
+        handler(pumpCallBackArgs);
+    };
+
+    if (isAsync)
+    {
+        var pumpHelper = function()
+        {
+            readHelper();
+            if (pumpCallBackArgs.bytesProcessed >= 0)
+            {
+                setTimeout(pumpHelper, 1);
+            }
+        };
+        setTimeout(pumpHelper, 1);
+    }
+    else
+    {
+        do
+        {
+            readHelper();
+        } while (pumpCallBackArgs.bytesProcessed >= 0);
+    }
+};