Simplify tests
parent
217357e185
commit
4d92c045de
|
@ -23,11 +23,9 @@ class ClientHandlerTest extends TestCase
|
||||||
$reader->write(new Message(new AdvancedJsonRpc\SuccessResponse($msg->body->id, 'pong')));
|
$reader->write(new Message(new AdvancedJsonRpc\SuccessResponse($msg->body->id, 'pong')));
|
||||||
}, 0);
|
}, 0);
|
||||||
});
|
});
|
||||||
$promise = $handler->request('testMethod', ['ping'])->then(function ($result) {
|
$handler->request('testMethod', ['ping'])->then(function ($result) {
|
||||||
$this->assertEquals('pong', $result);
|
$this->assertEquals('pong', $result);
|
||||||
});
|
})->wait();
|
||||||
Loop\tick();
|
|
||||||
$promise->wait();
|
|
||||||
// No event listeners
|
// No event listeners
|
||||||
$this->assertEquals([], $reader->listeners('message'));
|
$this->assertEquals([], $reader->listeners('message'));
|
||||||
$this->assertEquals([], $writer->listeners('message'));
|
$this->assertEquals([], $writer->listeners('message'));
|
||||||
|
@ -38,9 +36,7 @@ class ClientHandlerTest extends TestCase
|
||||||
$reader = new MockProtocolStream;
|
$reader = new MockProtocolStream;
|
||||||
$writer = new MockProtocolStream;
|
$writer = new MockProtocolStream;
|
||||||
$handler = new ClientHandler($reader, $writer);
|
$handler = new ClientHandler($reader, $writer);
|
||||||
$promise = $handler->notify('testMethod', ['ping']);
|
$handler->notify('testMethod', ['ping'])->wait();
|
||||||
Loop\tick();
|
|
||||||
$promise->wait();
|
|
||||||
// No event listeners
|
// No event listeners
|
||||||
$this->assertEquals([], $reader->listeners('message'));
|
$this->assertEquals([], $reader->listeners('message'));
|
||||||
$this->assertEquals([], $writer->listeners('message'));
|
$this->assertEquals([], $writer->listeners('message'));
|
||||||
|
|
Loading…
Reference in New Issue