1234567891011121314151617181920212223242526272829303132333435363738394041 |
- <?php
- namespace Predis\Connection;
- class CompositeStreamConnectionTest extends PredisConnectionTestCase
- {
- const CONNECTION_CLASS = 'Predis\Connection\CompositeStreamConnection';
-
-
-
-
- public function testReadsMultibulkResponsesAsIterators()
- {
- $connection = $this->createConnection(true);
- $profile = $this->getCurrentProfile();
- $connection->getProtocol()->useIterableMultibulk(true);
- $connection->executeCommand($profile->createCommand('rpush', array('metavars', 'foo', 'hoge', 'lol')));
- $connection->writeRequest($profile->createCommand('lrange', array('metavars', 0, -1)));
- $this->assertInstanceOf('Predis\Response\Iterator\MultiBulkIterator', $iterator = $connection->read());
- $this->assertSame(array('foo', 'hoge', 'lol'), iterator_to_array($iterator));
- }
- }
|