123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124 |
- <?php
- namespace Predis\Response\Iterator;
- use Predis\Client;
- use Predis\Connection\CompositeStreamConnection;
- use Predis\Protocol\Text\ProtocolProcessor as TextProtocolProcessor;
- use PredisTestCase;
- class MultiBulkTupleTest extends PredisTestCase
- {
-
- public function testInitiatedMultiBulkIteratorsAreNotValid()
- {
- $connection = $this->getMock('Predis\Connection\NodeConnectionInterface');
- $iterator = new MultiBulk($connection, 2);
- $iterator->next();
- new MultiBulkTuple($iterator);
- }
-
- public function testMultiBulkWithOddSizesAreInvalid()
- {
- $connection = $this->getMock('Predis\Connection\NodeConnectionInterface');
- $iterator = new MultiBulk($connection, 3);
- new MultiBulkTuple($iterator);
- }
-
- public function testIterableMultibulk()
- {
- $client = $this->getClient();
- $client->zadd('metavars', 1, 'foo', 2, 'hoge', 3, 'lol');
- $iterator = new MultiBulkTuple($client->zrange('metavars', '0', '-1', 'withscores'));
- $this->assertInstanceOf('OuterIterator', $iterator);
- $this->assertInstanceOf('Predis\Response\Iterator\MultiBulkTuple', $iterator);
- $this->assertInstanceOf('Predis\Response\Iterator\MultiBulk', $iterator->getInnerIterator());
- $this->assertTrue($iterator->valid());
- $this->assertSame(3, $iterator->count());
- $this->assertSame(array('foo', '1'), $iterator->current());
- $iterator->next();
- $this->assertTrue($iterator->valid());
- $this->assertSame(array('hoge', '2'), $iterator->current());
- $iterator->next();
- $this->assertTrue($iterator->valid());
- $this->assertSame(array('lol', '3'), $iterator->current());
- $iterator->next();
- $this->assertFalse($iterator->valid());
- $this->assertEquals('PONG', $client->ping());
- }
-
- public function testGarbageCollectorDropsUnderlyingConnection()
- {
- $client = $this->getClient();
- $client->zadd('metavars', 1, 'foo', 2, 'hoge', 3, 'lol');
- $iterator = new MultiBulkTuple($client->zrange('metavars', '0', '-1', 'withscores'));
- unset($iterator);
- $this->assertFalse($client->isConnected());
- $this->assertEquals('PONG', $client->ping());
- }
-
-
-
-
- protected function getClient()
- {
- $parameters = $this->getParameters(array('read_write_timeout' => 2));
- $protocol = new TextProtocolProcessor();
- $protocol->useIterableMultibulk(true);
- $connection = new CompositeStreamConnection($parameters, $protocol);
- $client = new Client($connection);
- $client->connect();
- $client->flushdb();
- return $client;
- }
- }
|