0.70.1

* Fix opening streams for table and stream action results

Author: a-hansen

build.gradle

@@ -5,7 +5,7 @@ subprojects {
     apply plugin: 'maven'
 
     group 'org.iot-dsa'
-    version '0.70.0'
+    version '0.70.1'
 
     targetCompatibility = JavaVersion.VERSION_1_8
     sourceCompatibility = JavaVersion.VERSION_1_8

dslink-v2/src/main/java/com/acuity/iot/dsa/dslink/protocol/responder/DSInboundInvoke.java

@@ -48,6 +48,7 @@ public class DSInboundInvoke extends DSInboundRequest
     private DSPermission permission;
     private ActionResults results;
     private int state = STATE_INIT;
+    private boolean streamOpen = false;
     private DSInfo target;
     private PassThruUpdate updateHead;
     private PassThruUpdate updateTail;
@@ -234,6 +235,16 @@ public boolean write(DSSession session, MessageWriter writer) {
                 writeClose(writer);
             }
             doClose();
+        } else {
+            switch (results.getResultsType()) {
+                case STREAM:
+                case TABLE:
+                    if (!streamOpen) {
+                        streamOpen = true;
+                        writeOpen(writer);
+                    }
+                default:
+            }
         }
         writeEnd(writer);
         return true;