1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768 |
- <?php
- namespace Predis\Pipeline;
- use Predis\Client;
- use PredisTestCase;
- class FireAndForgetTest extends PredisTestCase
- {
-
- public function testPipelineWithSingleConnection()
- {
- $connection = $this->getMock('Predis\Connection\NodeConnectionInterface');
- $connection
- ->expects($this->exactly(3))
- ->method('writeRequest');
- $connection
- ->expects($this->never())
- ->method('readResponse');
- $pipeline = new FireAndForget(new Client($connection));
- $pipeline->ping();
- $pipeline->ping();
- $pipeline->ping();
- $this->assertEmpty($pipeline->execute());
- }
-
- public function testSwitchesToMasterWithReplicationConnection()
- {
- $connection = $this->getMock('Predis\Connection\Replication\ReplicationInterface');
- $connection
- ->expects($this->once())
- ->method('switchToMaster');
- $connection
- ->expects($this->exactly(3))
- ->method('writeRequest');
- $connection
- ->expects($this->never())
- ->method('readResponse');
- $pipeline = new FireAndForget(new Client($connection));
- $pipeline->ping();
- $pipeline->ping();
- $pipeline->ping();
- $this->assertEmpty($pipeline->execute());
- }
- }
|