lib/slack/real_time/concurrency/async.rb in slack-ruby-client-0.17.0 vs lib/slack/real_time/concurrency/async.rb in slack-ruby-client-1.0.0

@@ -43,17 +43,15 @@
 
               while @restart
                 @client_task&.stop
 
                 @client_task = task.async do |subtask|
-                  begin
-                    subtask.annotate "#{client} run-loop"
-                    client.run_loop
-                  rescue ::Async::Wrapper::Cancelled => e
-                    # Will get restarted by ping worker.
-                  rescue StandardError => e
-                    client.logger.error(subtask.to_s) { e.message }
-                  end
+                  subtask.annotate "#{client} run-loop"
+                  client.run_loop
+                rescue ::Async::Wrapper::Cancelled => e
+                # Will get restarted by ping worker.
+                rescue StandardError => e
+                  client.logger.error(subtask.to_s) { e.message }
                 end
 
                 @restart.wait
               end