Raise errors when asked to do so in {UVTransport|UVStreamServer}._fatal_error

Author: 1st1

uvloop/handles/basetransport.pyx

@@ -39,10 +39,15 @@ cdef class UVBaseTransport(UVSocketHandle):
     cdef _fatal_error(self, exc, throw, reason=None):
         # Overload UVHandle._fatal_error
 
+        self._force_close(exc)
+
         if not isinstance(exc, (BrokenPipeError,
                                 ConnectionResetError,
                                 ConnectionAbortedError)):
 
+            if throw or self._loop is None:
+                raise exc
+
             msg = 'Fatal error on transport {}'.format(
                     self.__class__.__name__)
             if reason is not None:
@@ -55,8 +60,6 @@ cdef class UVBaseTransport(UVSocketHandle):
                 'protocol': self._protocol,
             })
 
-        self._force_close(exc)
-
     cdef inline _set_write_buffer_limits(self, int high=-1, int low=-1):
         if high == -1:
             if low == -1:

uvloop/handles/streamserver.pyx

@@ -65,10 +65,15 @@ cdef class UVStreamServer(UVSocketHandle):
     cdef _fatal_error(self, exc, throw, reason=None):
         # Overload UVHandle._fatal_error
 
+        self._close()
+
         if not isinstance(exc, (BrokenPipeError,
                                 ConnectionResetError,
                                 ConnectionAbortedError)):
 
+            if throw or self._loop is None:
+                raise exc
+
             msg = 'Fatal error on server {}'.format(
                     self.__class__.__name__)
             if reason is not None:
@@ -79,8 +84,6 @@ cdef class UVStreamServer(UVSocketHandle):
                 'exception': exc,
             })
 
-        self._close()
-
     cdef inline _mark_as_open(self):
         self.opened = 1