lib/google/cloud/speech/stream.rb in google-cloud-speech-0.28.0 vs lib/google/cloud/speech/stream.rb in google-cloud-speech-0.29.0

@@ -117,11 +117,12 @@
         def send bytes
           start # lazily call start if the stream wasn't started yet
           # TODO: do not send if stopped?
           synchronize do
             req = V1::StreamingRecognizeRequest.new(
-              audio_content: bytes.encode("ASCII-8BIT"))
+              audio_content: bytes.encode("ASCII-8BIT")
+            )
             @request_queue.push req
           end
         end
 
         ##
@@ -487,15 +488,15 @@
           response_enum.each do |response|
             begin
               background_results response
               background_event_type response.speech_event_type
               background_error response.error
-            rescue => e
+            rescue StandardError => e
               error! Google::Cloud::Error.from_error(e)
             end
           end
-        rescue => e
+        rescue StandardError => e
           error! Google::Cloud::Error.from_error(e)
         ensure
           pass_complete!
           Thread.pass
         end
@@ -530,11 +531,11 @@
 
         def background_error error
           return if error.nil?
 
           require "grpc/errors"
-          fail GRPC::BadStatus.new(error.code, error.message)
+          raise GRPC::BadStatus.new(error.code, error.message)
         end
 
         # @private
         class EnumeratorQueue
           extend Forwardable
@@ -550,10 +551,10 @@
           def each_item
             return enum_for(:each_item) unless block_given?
             loop do
               r = @q.pop
               break if r.equal? @sentinel
-              fail r if r.is_a? Exception
+              raise r if r.is_a? Exception
               yield r
             end
           end
         end
       end