fix: Fixing the shutdown logic for streaming subscriber connection (#…

…1613) * fix: Fixing the shutdown logic for streaming subscriber connection * fix: Fixing the shutdown logic for streaming subscriber connection * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
googleapis · Jun 20, 2023 · 09aff9c · 09aff9c
1 parent b3f2dff
commit 09aff9c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java b/...-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java
@@ -191,15 +191,14 @@ protected void doStart() {
 
  @Override
  protected void doStop() {
- runShutdown();
-
  lock.lock();
  try {
  clientStream.closeSendWithError(Status.CANCELLED.asException());
  } finally {
  lock.unlock();
- notifyStopped();
  }
+ runShutdown();
+ notifyStopped();
  }
 
  private void runShutdown() {