1.0.84

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartuniverse",
-  "version": "1.0.83",
+  "version": "1.0.84",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartuniverse",
-  "version": "1.0.83",
+  "version": "1.0.84",
   "private": false,
   "description": "messaging service for your micro services",
   "main": "dist/index.js",

ts/smartuniverse.classes.reactionrequest.ts

@@ -49,7 +49,7 @@ export class ReactionRequest<T extends plugins.typedrequestInterfaces.ITypedRequ
           request: requestDataArg,
           response: null
         }
-      }
+      };
       channel.sendMessage({
         messageText: 'reactionRequest',
         payload

ts/smartuniverse.classes.reactionresult.ts

@@ -16,11 +16,26 @@ export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedReque
     return this.resultSubject.subscribe(observerArg);
   }
 
+  /**
+   * gets the end result as an array of all results
+   */
   public async getEndResult() {
     const result = await this.completeDeferred.promise;
     return result;
   }
 
+  /**
+   * if there is a single respondant, or you are only interested in the first result
+   */
+  public async getFirstResult() {
+    const done = plugins.smartpromise.defer<T['response']>();
+    const subscription = this.resultSubject.subscribe(result => {
+      done.resolve(result);
+      subscription.unsubscribe();
+    });
+    return await done.promise;
+  }
+
   /**
    * push a reactionResponse
    */