feat: add the getTradesStream method

b2broker · Sep 22, 2020 · fcfc701 · fcfc701
1 parent 8abf277
commit fcfc701
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/src/rest.ts b/src/rest.ts
@@ -91,6 +91,13 @@ export interface ISymbolIdType extends IVersion {
   symbolType: string;
 }
 
+export interface ISymbolIds {
+  /**
+   * Financial instrument id
+   */
+  symbolIds: string | string[];
+}
+
 export interface ILastQuoteOptions extends IVersion {
   /**
    * Symbol id or symbol ids
@@ -1321,6 +1328,15 @@ export class RestClient {
     return exchanges;
   }
 
+  /**
+   * Get the trades stream for the specified financial instrument
+   */
+  public async getTradesStream({ symbolIds }: ISymbolIds): Promise<JSONStream> {
+    const url = new URL(`/md/3.0/feed/trades/${symbolIds}`, this.url);
+    const stream = await this.fetchStream(url);
+    return stream;
+  }
+
   /**
    * Get the list of OHLC candles
    */