Minor updates for live coding for GIDS

infinispan-demos · Apr 26, 2018 · 4d460cd · 4d460cd
1 parent 92103c1
commit 4d460cd
Show file tree

Hide file tree

Showing 4 changed files with 32 additions and 19 deletions.
diff --git a/app/src/main/java/app/AppUtils.java b/app/src/main/java/app/AppUtils.java
@@ -127,7 +127,8 @@ private static URL getUrl(String resource) {
   }
 
   private static Flowable<Long> throttle() {
-    return Flowable.interval(5, TimeUnit.MILLISECONDS).onBackpressureDrop();
+    // TODO live coding 1.50 - change throttle to 5 ms
+    return Flowable.interval(1000, TimeUnit.MILLISECONDS).onBackpressureDrop();
   }
 
 }
diff --git a/app/src/main/java/app/StationBoardsVerticle.java b/app/src/main/java/app/StationBoardsVerticle.java
@@ -177,15 +177,19 @@ public void stop(io.vertx.core.Future<Void> future) {
     if (injectorDisposable != null)
       injectorDisposable.dispose();
 
-    stationBoardsMap.removeContinuousQueries()
-      .andThen(stationBoardsMap.close())
-      .subscribe(
-        () -> {
-          log.info("Stopped station boards verticle");
-          future.complete();
-        }
-        , future::fail
-      );
+    if (stationBoardsMap != null) {
+      stationBoardsMap.removeContinuousQueries()
+        .andThen(stationBoardsMap.close())
+        .subscribe(
+          () -> {
+            log.info("Stopped station boards verticle");
+            future.complete();
+          }
+          , future::fail
+        );
+    } else {
+      future.complete();
+    }
   }
 
 }
diff --git a/app/src/main/solution/app/StationBoardsVerticle.java b/app/src/main/solution/app/StationBoardsVerticle.java
@@ -164,15 +164,19 @@ public void stop(io.vertx.core.Future<Void> future) {
     if (injectorDisposable != null)
       injectorDisposable.dispose();
 
-    stationBoardsMap.removeContinuousQueries()
-      .andThen(stationBoardsMap.close())
-      .subscribe(
-        () -> {
-          log.info("Stopped station boards verticle");
-          future.complete();
-        }
-        , future::fail
-      );
+    if (stationBoardsMap != null) {
+      stationBoardsMap.removeContinuousQueries()
+        .andThen(stationBoardsMap.close())
+        .subscribe(
+          () -> {
+            log.info("Stopped station boards verticle");
+            future.complete();
+          }
+          , future::fail
+        );
+    } else {
+      future.complete();
+    }
   }
 
 }
diff --git a/live-coding/gids-18.org b/live-coding/gids-18.org
@@ -68,6 +68,10 @@ stationBoardsMap.clear()
 #+BEGIN_SRC java
 .flatMapCompletable(e -> stationBoardsMap.put(e.getKey(), e.getValue()))
 #+END_SRC
+*** Change throttle from 1000ms to 5ms
+#+BEGIN_SRC java
+Flowable.interval(5, TimeUnit.MILLISECONDS).onBackpressureDrop();
+#+END_SRC
 *** Deploy changes
 #+BEGIN_SRC shell
 > cd app