feat: add requestMultiple method for supporting streaming pagination t…

…heY4Kman#22.

src/index.ts

@@ -13,6 +13,8 @@ import {
   ISerializer,
   IStreamingAPI,
   ITransport,
+  RequestMultipleCancel,
+  RequestMultipleHandler,
   SubscribeOptions,
   SubscriptionHandler,
 } from './interface';
@@ -298,6 +300,26 @@ class DCRFClient implements IStreamingAPI {
     });
   }
 
+  public requestMultiple(stream: string, payload: object, requestId: string = UUID.generate(), callback: RequestMultipleHandler): RequestMultipleCancel {
+    const selector = this.buildRequestResponseSelector(stream, requestId);
+
+    const listenerId = this.dispatcher.listen(selector, (data: typeof selector & { payload: { response_status: number, data: any } }) => {
+      const {payload: response} = data;
+      const responseStatus = response.response_status;
+
+      // 2xx is success
+      if (Math.floor(responseStatus / 100) === 2) {
+        callback(null, response.data);
+      } else {
+        callback(response, null);
+      }
+    });
+
+    return () => {
+      this.dispatcher.cancel(listenerId);
+    };
+  }
+
   public send(object: object) {
     return this.doSend(object, this.queue.send);
   }

src/interface.ts

@@ -11,6 +11,11 @@ type DispatchListener<T> = (response: T) => any;
 export
 type SubscriptionHandler = (payload: {[prop: string]: any}, action: string) => any;
 
+export
+type RequestMultipleHandler = (error: {response_status: number, data: any} | null, payload: {[prop: string]: any} | null) => any;
+
+export
+type RequestMultipleCancel = () => void;
 
 /**
  * Calls all handlers whose selectors match an incoming payload.