lib/asir/transport.rb in asir-1.2.1 vs lib/asir/transport.rb in asir-1.2.2

@@ -155,10 +155,12 @@
         end
         self
       else
         nil
       end
+    rescue *Error::Unrecoverable.modules
+      raise
     rescue ::Exception => exc
       exception = original_exception = exc
       _log [ :message_error, exc ]
       @on_exception.call(self, exc, :message, state) if @on_exception
     ensure
@@ -173,9 +175,11 @@
           end
           if out_stream
             send_result(state)
           end
         end
+      rescue *Error::Unrecoverable.modules
+        raise
       rescue ::Exception => exc
         _log [ :result_error, exc, exc.backtrace ]
         @on_exception.call(self, exc, :result, state) if @on_exception
       end
       raise original_exception if unforwardable_exception