Code style change

amphp · Jul 2, 2023 · 022ace9 · 022ace9
1 parent 2c297e1
commit 022ace9
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 12 deletions.
diff --git a/src/Connection/Internal/Http1Parser.php b/src/Connection/Internal/Http1Parser.php
@@ -115,10 +115,9 @@ public function parse(string $data = null): ?Response
 
  if (!$this->bodyStarted && \in_array($this->state, [self::BODY_CHUNKS, self::BODY_IDENTITY, self::BODY_IDENTITY_EOF], true)) {
  $this->bodyStarted = true;
-
- $eventInvoker = events();
- \assert($this->response !== null);
- $eventInvoker->responseBodyStart($this->request, $this->stream, $this->response);
+ $response = $this->response;
+ \assert($response !== null);
+ events()->responseBodyStart($this->request, $this->stream, $response);
  }
 
  switch ($this->state) {

diff --git a/src/Connection/Internal/Http2ConnectionProcessor.php b/src/Connection/Internal/Http2ConnectionProcessor.php
@@ -779,15 +779,15 @@ public function handleData(int $streamId, string $data): void
  return;
  }
 
- $eventInvoker = events();
- \assert($stream->response !== null);
+ $response = $stream->response;
+ \assert($response !== null);
 
  if (!$stream->bodyStarted) {
  $stream->bodyStarted = true;
- $eventInvoker->responseBodyStart($stream->request, $stream->stream, $stream->response);
+ events()->responseBodyStart($stream->request, $stream->stream, $response);
  }
 
- $eventInvoker->responseBodyProgress($stream->request, $stream->stream, $stream->response);
+ events()->responseBodyProgress($stream->request, $stream->stream, $response);
 
  $stream->body?->pushAsync($data)->map(function () use ($streamId, $length): void {
  $stream = $this->streams[$streamId] ?? null;
@@ -842,15 +842,15 @@ public function handleStreamEnd(int $streamId): void
  $stream->body->complete();
  $stream->body = null;
 
- $eventInvoker = events();
+ $response = $stream->response;
+ \assert($response !== null);
 
  if (EventInvoker::getPhase($stream->request) === Phase::ResponseHeaders) {
- \assert($stream->response !== null);
- $eventInvoker->responseBodyStart($stream->request, $stream->stream, $stream->response);
+ events()->responseBodyStart($stream->request, $stream->stream, $response);
  }
 
  \assert($stream->response !== null);
- $eventInvoker->responseBodyEnd($stream->request, $stream->stream, $stream->response);
+ events()->responseBodyEnd($stream->request, $stream->stream, $response);
 
  // Trailers may have been received in handleHeaders(); if not, resolve with an empty set of trailers.
  if ($stream->trailers !== null) {