Skip to content

Commit b2f1658

Browse files
committed
Simplify rejecting request when connection is ending
1 parent 34510c1 commit b2f1658

File tree

1 file changed

+6
-12
lines changed

1 file changed

+6
-12
lines changed

src/Client.php

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -69,21 +69,15 @@ public function __construct(Stream $stream, ParserInterface $parser = null, Seri
6969

7070
public function __call($name, $args)
7171
{
72-
if ($this->ending) {
73-
$e = new RuntimeException('Connection closed');
72+
$request = new Deferred();
7473

75-
if (class_exists('React\Promise\When')) {
76-
return \React\Promise\When::reject($e);
77-
} else {
78-
return \React\Promise\reject($e);
79-
}
74+
if ($this->ending) {
75+
$request->reject(new RuntimeException('Connection closed'));
76+
} else {
77+
$this->stream->write($this->serializer->getRequestMessage($name, $args));
78+
$this->requests []= $request;
8079
}
8180

82-
$this->stream->write($this->serializer->getRequestMessage($name, $args));
83-
84-
$request = new Deferred();
85-
$this->requests []= $request;
86-
8781
return $request->promise();
8882
}
8983

0 commit comments

Comments
 (0)