batch the events

ryantxu · Oct 9, 2019 · 33051a4 · 33051a4
1 parent ffb3f60
commit 33051a4
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 6 deletions.
diff --git a/server/SimpleHIDServer/.gitignore b/server/SimpleHIDServer/.gitignore
@@ -1,4 +1,5 @@
-.vscode
+.vscode/
+.vs/
 bin/
 obj/
 packages/

diff --git a/src/StreamingListener.ts b/src/StreamingListener.ts
@@ -1,4 +1,4 @@
-import { TimeSeriesMessage } from 'types';
+import { TimeSeriesMessage, TimeSeriesValue } from './types';
 import { KeyValue, CircularDataFrame, FieldType, LoadingState, DataFrame } from '@grafana/data';
 import { Subject, Observable, ReplaySubject } from 'rxjs';
 import { webSocket, WebSocketSubject } from 'rxjs/webSocket';
@@ -33,8 +33,10 @@ export class StreamListener {
         },
       });
       this.stream!.subscribe({
-        next: (msg: any) => {
-          this.process(msg as TimeSeriesMessage);
+        next: (msg: TimeSeriesMessage) => {
+          for (const evt of msg.events) {
+            this.process(evt);
+          }
         },
       });
     } else {
@@ -100,7 +102,7 @@ export class StreamListener {
     return this.getOrCreate(name).subject;
   }
 
-  process(msg: TimeSeriesMessage) {
+  process(msg: TimeSeriesValue) {
     const info = this.getOrCreate(msg.name);
     const df = info.frame;
     if (!df.fields.length) {

diff --git a/src/types.ts b/src/types.ts
@@ -12,9 +12,13 @@ export interface MyDataSourceOptions extends DataSourceJsonData {
   apiKey?: string;
 }
 
-export interface TimeSeriesMessage {
+export interface TimeSeriesValue {
   name: string; // Name of the field
   config?: FieldConfig; // optionally include field config
   time?: number;
   value?: any;
 }
+
+export interface TimeSeriesMessage {
+  events: TimeSeriesValue[];
+}