fix(pubsub): Move Thread.new to end of AsyncPublisher#initialize

fixes: #4280 pr: #4820
googleapis · Feb 14, 2020 · d293186 · d293186
1 parent 0d118ba
commit d293186
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/google-cloud-pubsub/lib/google/cloud/pubsub/async_publisher.rb b/google-cloud-pubsub/lib/google/cloud/pubsub/async_publisher.rb
@@ -83,12 +83,12 @@ def initialize topic_name, service, max_bytes: 1_000_000, max_messages: 100, int
           @published_at = nil
           @publish_thread_pool = Concurrent::ThreadPoolExecutor.new max_threads: @publish_threads
           @callback_thread_pool = Concurrent::ThreadPoolExecutor.new max_threads: @callback_threads
-          @thread = Thread.new { run_background }
 
           @ordered = false
           @batches = {}
-
           @cond = new_cond
+
+          @thread = Thread.new { run_background }
         end
 
         ##