Code review

Author: fabianfett

Sources/AsyncHTTPClient/RequestBag.swift

@@ -81,7 +81,8 @@ final class RequestBag<Delegate: HTTPClientResponseDelegate> {
     // MARK: - Request -
 
     private func willExecuteRequest0(_ executor: HTTPRequestExecutor) {
-        guard self.state.willExecuteRequest(executor) else {
+        self.task.eventLoop.assertInEventLoop()
+        if !self.state.willExecuteRequest(executor) {
             return executor.cancelRequest(self)
         }
     }
@@ -240,6 +241,8 @@ final class RequestBag<Delegate: HTTPClientResponseDelegate> {
                     case .success:
                         self.consumeMoreBodyData0(resultOfPreviousConsume: $0)
                     case .failure(let error):
+                        // if in the response stream consumption an error has occurred, we need to
+                        // cancel the running request and fail the task.
                         self.fail(error)
                     }
                 }