throw on onStart

googleapis · Oct 7, 2022 · 4720481 · 4720481
1 parent 4517183
commit 4720481
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...d-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/SafeResponseObserver.java b/...d-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/SafeResponseObserver.java
@@ -42,8 +42,7 @@ public SafeResponseObserver(ResponseObserver outerObserver) {
   @Override
   public final void onStart(StreamController streamController) {
     if (!isStarted.compareAndSet(false, true)) {
-      logException("A stream is already started");
-      return;
+      throw new IllegalStateException("A stream is already started");
     }
 
     this.streamController = streamController;