123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114 |
- <?php
- namespace Predis\Iterator;
- use PredisTestCase;
- use Predis\Client;
- class MultiBulkResponseTupleTest extends PredisTestCase
- {
-
- public function testInitiatedMultiBulkIteratorsAreNotValid()
- {
- $connection = $this->getMock('Predis\Connection\SingleConnectionInterface');
- $iterator = new MultiBulkResponseSimple($connection, 2);
- $iterator->next();
- new MultiBulkResponseTuple($iterator);
- }
-
- public function testMultiBulkWithOddSizesAreInvalid()
- {
- $connection = $this->getMock('Predis\Connection\SingleConnectionInterface');
- $iterator = new MultiBulkResponseSimple($connection, 3);
- new MultiBulkResponseTuple($iterator);
- }
-
- public function testIterableMultibulk()
- {
- $client = $this->getClient();
- $client->zadd('metavars', 1, 'foo', 2, 'hoge', 3, 'lol');
- $this->assertInstanceOf('OuterIterator', $iterator = $client->zrange('metavars', 0, -1, 'withscores')->asTuple());
- $this->assertInstanceOf('Predis\Iterator\MultiBulkResponseTuple', $iterator);
- $this->assertInstanceOf('Predis\Iterator\MultiBulkResponseSimple', $iterator->getInnerIterator());
- $this->assertTrue($iterator->valid());
- $this->assertSame(3, $iterator->count());
- $this->assertSame(array('foo', '1'), $iterator->current());
- $this->assertSame(1, $iterator->next());
- $this->assertTrue($iterator->valid());
- $this->assertSame(array('hoge', '2'), $iterator->current());
- $this->assertSame(2, $iterator->next());
- $this->assertTrue($iterator->valid());
- $this->assertSame(array('lol', '3'), $iterator->current());
- $this->assertSame(3, $iterator->next());
- $this->assertFalse($iterator->valid());
- $this->assertTrue($client->ping());
- }
-
- public function testGarbageCollectorDropsUnderlyingConnection()
- {
- $client = $this->getClient();
- $client->zadd('metavars', 1, 'foo', 2, 'hoge', 3, 'lol');
- $iterator = $client->zrange('metavars', 0, -1, 'withscores')->asTuple();
- unset($iterator);
- $this->assertFalse($client->isConnected());
- $this->assertTrue($client->ping());
- }
-
-
-
-
- protected function getClient()
- {
- $parameters = $this->getParametersArray(array(
- 'iterable_multibulk' => true,
- 'read_write_timeout' => 2,
- ));
- $client = $this->createClient($parameters);
- return $client;
- }
- }
|