update feed consumer

briangu · Dec 14, 2023 · aef0250 · aef0250
1 parent dc0c450
commit aef0250
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/stocks/alpaca/ws/feed_consumer.kg b/examples/stocks/alpaca/ws/feed_consumer.kg
@@ -68,8 +68,8 @@ timeAnalyze::{time(analyze)}
 analyzeComplete::{.d("analyze ms: ");.p(x)}
 asyncAnalyze::.async(timeAnalyze;analyzeComplete)
 
-updateDb::{[u d];u::x;d::{u?x}'cols;.d("insert: ");.d(d);.insert(prices;d)}
-timeUpdateDb::{[ms];ms::time1(updateDb;x);.d(" ");.d(ms);.p(" ms")}
+updateDb::{.insert(prices;x@cols)}
+timeUpdateDb::{.d("insert: ");.d(x@cols);.d(" ");.d(time1(updateDb;x));.p(" ms")}
 
 :" Called by server when there is a subscription update."
 update::{timeUpdateDb(x);asyncAnalyze()}