How to use stream_read method of has class

Best VfsStream code snippet using has.stream_read

controller.php

Source:controller.php

...70			->then71				->object($controller->contains('abcdefghijklmnopqrstuvwxyz'))->isIdenticalTo($controller)72			->if($controller->stream_open(uniqid(), 'r', 0))73			->then74				->string($controller->stream_read(1))->isEqualTo('a')75				->boolean($controller->stream_eof())->isFalse()76				->string($controller->stream_read(1))->isEqualTo('b')77				->boolean($controller->stream_eof())->isFalse()78				->string($controller->stream_read(2))->isEqualTo('cd')79				->boolean($controller->stream_eof())->isFalse()80				->string($controller->stream_read(4096))->isEqualTo('efghijklmnopqrstuvwxyz')81				->boolean($controller->stream_eof())->isTrue()82				->string($controller->stream_read(1))->isEmpty()83		;84	}85	public function testIsEmpty()86	{87		$this88			->if($controller = new testedClass(uniqid()))89			->and($controller->contains('abcdefghijklmnopqrstuvwxyz'))90			->then91				->object($controller->isEmpty())->isIdenticalTo($controller)92				->string($controller->getContents())->isEmpty()93		;94	}95	public function testExists()96	{97		$this98			->if($controller = new testedClass(uniqid()))99			->then100				->object($controller->exists())->isIdenticalTo($controller)101				->array($controller->stream_stat())->isNotEmpty()102			->if($controller->notExists())103			->then104				->object($controller->exists())->isIdenticalTo($controller)105				->array($controller->stream_stat())->isNotEmpty()106		;107	}108	public function testNotExists()109	{110		$this111			->if($controller = new testedClass(uniqid()))112			->then113				->object($controller->notExists())->isIdenticalTo($controller)114				->boolean($controller->stream_stat())->isFalse()115		;116	}117	public function testIsNotReadable()118	{119		$this120			->if($controller = new testedClass(uniqid()))121			->then122				->object($controller->isNotReadable())->isIdenticalTo($controller)123				->integer($controller->getMode())->isEqualTo(200)124				->object($controller->isNotReadable())->isIdenticalTo($controller)125				->integer($controller->getMode())->isEqualTo(200)126		;127	}128	public function testIsReadable()129	{130		$this131			->if($controller = new testedClass(uniqid()))132			->then133				->object($controller->isReadable())->isIdenticalTo($controller)134				->integer($controller->getMode())->isEqualTo(644)135				->object($controller->isReadable())->isIdenticalTo($controller)136				->integer($controller->getMode())->isEqualTo(644)137			->if($controller->isNotReadable())138			->then139				->object($controller->isReadable())->isIdenticalTo($controller)140				->integer($controller->getMode())->isEqualTo(644)141				->object($controller->isReadable())->isIdenticalTo($controller)142				->integer($controller->getMode())->isEqualTo(644)143		;144	}145	public function testIsNotWritable()146	{147		$this148			->if($controller = new testedClass(uniqid()))149			->then150				->object($controller->isNotWritable())->isIdenticalTo($controller)151				->integer($controller->getMode())->isEqualTo(444)152				->object($controller->isNotWritable())->isIdenticalTo($controller)153				->integer($controller->getMode())->isEqualTo(444)154		;155	}156	public function testIsWritable()157	{158		$this159			->if($controller = new testedClass(uniqid()))160			->and($controller->isNotWritable())161			->then162				->object($controller->isWritable())->isIdenticalTo($controller)163				->integer($controller->getMode())->isEqualTo(666)164				->object($controller->isWritable())->isIdenticalTo($controller)165				->integer($controller->getMode())->isEqualTo(666)166		;167	}168	public function testIsExecutable()169	{170		$this171			->if($controller = new testedClass(uniqid()))172			->then173				->object($controller->isExecutable())->isIdenticalTo($controller)174				->integer($controller->getMode())->isEqualTo(755)175				->object($controller->isExecutable())->isIdenticalTo($controller)176				->integer($controller->getMode())->isEqualTo(755)177		;178	}179	public function testIsNotExecutable()180	{181		$this182			->if($controller = new testedClass(uniqid()))183			->and($controller->isExecutable())184			->then185				->object($controller->isNotExecutable())->isIdenticalTo($controller)186				->integer($controller->getMode())->isEqualTo(644)187				->object($controller->isNotExecutable())->isIdenticalTo($controller)188				->integer($controller->getMode())->isEqualTo(644)189		;190	}191	public function testStreamOpen()192	{193		$this194			->assert('Use r and r+ mode')195				->if($controller = new testedClass(uniqid()))196				->then197					->boolean($controller->stream_open(uniqid(), 'z', 0))->isFalse()198					->array($controller->getCalls())->isNotEmpty()199					->boolean($controller->stream_open(uniqid(), 'z', STREAM_REPORT_ERRORS))->isFalse()200					->error('Operation timed out', E_USER_WARNING)->exists()201					->boolean($controller->stream_open(uniqid(), 'r', 0))->isTrue()202					->integer($controller->stream_tell())->isZero()203					->string($controller->stream_read(1))->isEmpty()204					->integer($controller->stream_write('a'))->isZero()205					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isTrue()206					->integer($controller->stream_tell())->isZero()207					->string($controller->stream_read(1))->isEmpty()208					->integer($controller->stream_write('a'))->isEqualTo(1)209					->boolean($controller->stream_open(uniqid(), 'r', STREAM_USE_PATH, $path))->isTrue()210					->string($path)->isEqualTo($controller->getPath())211					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_USE_PATH, $path))->isTrue()212					->string($path)->isEqualTo($controller->getPath())213				->if($controller->setContents('abcdefghijklmnopqrstuvwxyz'))214				->then215					->boolean($controller->stream_open(uniqid(), 'r', 0))->isTrue()216					->array($controller->getCalls())->isNotEmpty()217					->integer($controller->stream_tell())->isZero()218					->string($controller->stream_read(1))->isEqualTo('a')219					->integer($controller->stream_write('a'))->isZero()220					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isTrue()221					->integer($controller->stream_tell())->isZero()222					->string($controller->stream_read(1))->isEqualTo('a')223					->integer($controller->stream_write('a'))->isEqualTo(1)224					->boolean($controller->stream_open(uniqid(), 'r', STREAM_USE_PATH, $path))->isTrue()225					->string($path)->isEqualTo($controller->getPath())226					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_USE_PATH, $path))->isTrue()227					->string($path)->isEqualTo($controller->getPath())228				->if($controller->notExists())229				->then230					->boolean($controller->stream_open(uniqid(), 'r', 0))->isFalse()231					->array($controller->getCalls())->isNotEmpty()232					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isFalse()233					->boolean($controller->stream_open(uniqid(), 'r', STREAM_REPORT_ERRORS))->isFalse()234					->error('No such file or directory', E_USER_WARNING)->exists()235					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_REPORT_ERRORS))->isFalse()236					->error('No such file or directory', E_USER_WARNING)->exists()237					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isFalse()238					->boolean($controller->stream_open(uniqid(), 'r', STREAM_USE_PATH, $path))->isFalse()239					->variable($path)->isNull()240					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_USE_PATH, $path))->isFalse()241					->variable($path)->isNull()242				->if($controller->exists())243				->and($controller->isNotReadable())244				->then245					->boolean($controller->stream_open(uniqid(), 'r', 0))->isFalse()246					->array($controller->getCalls())->isNotEmpty()247					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isFalse()248					->boolean($controller->stream_open(uniqid(), 'r', STREAM_REPORT_ERRORS))->isFalse()249					->error('Permission denied', E_USER_WARNING)->exists()250					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_REPORT_ERRORS))->isFalse()251					->error('Permission denied', E_USER_WARNING)->exists()252					->boolean($controller->stream_open(uniqid(), 'r', STREAM_USE_PATH, $path))->isFalse()253					->variable($path)->isNull()254					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_USE_PATH, $path))->isFalse()255					->variable($path)->isNull()256				->if($controller->isReadable())257				->and($controller->isNotWritable())258					->boolean($controller->stream_open(uniqid(), 'r', 0))->isTrue()259					->array($controller->getCalls())->isNotEmpty()260					->boolean($controller->stream_open(uniqid(), 'r+', 0))->isFalse()261					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_REPORT_ERRORS))->isFalse()262					->error('Permission denied', E_USER_WARNING)->exists()263					->boolean($controller->stream_open(uniqid(), 'r', STREAM_USE_PATH, $path))->isTrue()264					->string($path)->isEqualTo($controller->getPath())265					->boolean($controller->stream_open(uniqid(), 'r+', STREAM_USE_PATH, $path))->isFalse()266					->variable($path)->isNull()267			->assert('Use w and w+ mode')268				->if($controller = new testedClass(uniqid()))269				->then270					->boolean($controller->stream_open(uniqid(), 'w', 0))->isTrue()271					->array($controller->getCalls())->isNotEmpty()272					->integer($controller->stream_tell())->isZero()273					->string($controller->stream_read(1))->isEmpty()274					->integer($controller->stream_write('a'))->isEqualTo(1)275					->boolean($controller->stream_open(uniqid(), 'w+', 0))->isTrue()276					->integer($controller->stream_tell())->isZero()277					->string($controller->stream_read(1))->isEmpty()278					->integer($controller->stream_write('a'))->isEqualTo(1)279					->boolean($controller->stream_open(uniqid(), 'w', STREAM_USE_PATH, $path))->isTrue()280					->string($path)->isEqualTo($controller->getPath())281					->boolean($controller->stream_open(uniqid(), 'w+', STREAM_USE_PATH, $path))->isTrue()282					->string($path)->isEqualTo($controller->getPath())283				->if($controller->setContents('abcdefghijklmnopqrstuvwxyz'))284				->then285					->boolean($controller->stream_open(uniqid(), 'w', 0))->isTrue()286					->array($controller->getCalls())->isNotEmpty()287					->integer($controller->stream_tell())->isZero()288					->string($controller->stream_read(1))->isEmpty()289					->integer($controller->stream_write('a'))->isEqualTo(1)290					->boolean($controller->stream_open(uniqid(), 'w+', 0))->isTrue()291					->integer($controller->stream_tell())->isZero()292					->string($controller->stream_read(1))->isEmpty()293					->integer($controller->stream_write('a'))->isEqualTo(1)294				->if($controller->isNotWritable())295				->then296					->boolean($controller->stream_open(uniqid(), 'w', 0))->isFalse()297					->array($controller->getCalls())->isNotEmpty()298					->boolean($controller->stream_open(uniqid(), 'w', STREAM_REPORT_ERRORS))->isFalse()299					->error('Permission denied', E_USER_WARNING)->exists()300					->boolean($controller->stream_open(uniqid(), 'w+', 0))->isFalse()301					->boolean($controller->stream_open(uniqid(), 'w+', STREAM_REPORT_ERRORS))->isFalse()302					->error('Permission denied', E_USER_WARNING)->exists()303			->assert('Use c and c+ mode')304				->if($controller = new testedClass(uniqid()))305				->then306					->boolean($controller->stream_open(uniqid(), 'c', 0))->isTrue()307					->array($controller->getCalls())->isNotEmpty()308					->integer($controller->stream_tell())->isZero()309					->string($controller->stream_read(1))->isEmpty()310					->integer($controller->stream_write('a'))->isEqualTo(1)311					->boolean($controller->stream_open(uniqid(), 'c+', 0))->isTrue()312					->integer($controller->stream_tell())->isZero()313					->string($controller->stream_read(1))->isEqualTo('a')314					->integer($controller->stream_write('a'))->isEqualTo(1)315					->boolean($controller->stream_open(uniqid(), 'c', STREAM_USE_PATH, $path))->isTrue()316					->string($path)->isEqualTo($controller->getPath())317					->boolean($controller->stream_open(uniqid(), 'c+', STREAM_USE_PATH, $path))->isTrue()318					->string($path)->isEqualTo($controller->getPath())319				->if($controller->setContents('abcdefghijklmnopqrstuvwxyz'))320				->then321					->boolean($controller->stream_open(uniqid(), 'c', 0))->isTrue()322					->array($controller->getCalls())->isNotEmpty()323					->integer($controller->stream_tell())->isZero()324					->string($controller->stream_read(1))->isEmpty()325					->integer($controller->stream_write('a'))->isEqualTo(1)326					->boolean($controller->stream_open(uniqid(), 'c+', 0))->isTrue()327					->integer($controller->stream_tell())->isZero()328					->string($controller->stream_read(1))->isEqualTo('a')329					->integer($controller->stream_write('a'))->isEqualTo(1)330				->if($controller->isNotWritable())331				->then332					->boolean($controller->stream_open(uniqid(), 'c', 0))->isFalse()333					->array($controller->getCalls())->isNotEmpty()334					->boolean($controller->stream_open(uniqid(), 'c', STREAM_REPORT_ERRORS))->isFalse()335					->error('Permission denied', E_USER_WARNING)->exists()336					->boolean($controller->stream_open(uniqid(), 'c+', 0))->isFalse()337					->boolean($controller->stream_open(uniqid(), 'c+', STREAM_REPORT_ERRORS))->isFalse()338					->error('Permission denied', E_USER_WARNING)->exists()339			->assert('Use a and a+ mode')340				->if($controller = new testedClass(uniqid()))341				->then342					->boolean($controller->stream_open(uniqid(), 'a', 0))->isTrue()343					->array($controller->getCalls())->isNotEmpty()344					->integer($controller->stream_tell())->isZero()345					->string($controller->stream_read(1))->isEmpty()346					->integer($controller->stream_write('a'))->isEqualTo(1)347					->string($controller->getContents())->isEqualTo('a')348					->integer($controller->stream_write('b'))->isEqualTo(1)349					->string($controller->getContents())->isEqualTo('ab')350					->boolean($controller->stream_open(uniqid(), 'a', 0))->isTrue()351					->integer($controller->stream_tell())->isZero()352					->string($controller->stream_read(1))->isEmpty()353					->integer($controller->stream_write('c'))->isEqualTo(1)354					->string($controller->getContents())->isEqualTo('ab' . PHP_EOL . 'c')355					->integer($controller->stream_write('d'))->isEqualTo(1)356					->string($controller->getContents())->isEqualTo('ab' . PHP_EOL . 'cd')357					->boolean($controller->stream_open(uniqid(), 'a+', 0))->isTrue()358					->integer($controller->stream_tell())->isZero()359					->string($controller->stream_read(1))->isEqualTo('a')360					->integer($controller->stream_write('e'))->isEqualTo(1)361					->string($controller->getContents())->isEqualTo('ab' . PHP_EOL . 'cd' . PHP_EOL . 'e')362				->if($controller->setContents('abcdefghijklmnopqrstuvwxyz'))363				->then364					->boolean($controller->stream_open(uniqid(), 'a', 0))->isTrue()365					->array($controller->getCalls())->isNotEmpty()366					->integer($controller->stream_tell())->isZero()367					->string($controller->stream_read(1))->isEmpty()368					->integer($controller->stream_write('A'))->isEqualTo(1)369					->string($controller->getContents())->isEqualTo('abcdefghijklmnopqrstuvwxyz' . PHP_EOL . 'A')370					->boolean($controller->stream_open(uniqid(), 'a+', 0))->isTrue()371					->array($controller->getCalls())->isNotEmpty()372					->integer($controller->stream_tell())->isZero()373					->string($controller->stream_read(1))->isEqualTo('a')374					->integer($controller->stream_write('B'))->isEqualTo(1)375					->string($controller->getContents())->isEqualTo('abcdefghijklmnopqrstuvwxyz' . PHP_EOL . 'A' . PHP_EOL . 'B')376					->integer($controller->stream_write('C'))->isEqualTo(1)377					->string($controller->getContents())->isEqualTo('abcdefghijklmnopqrstuvwxyz' . PHP_EOL . 'A' . PHP_EOL . 'BC')378				->if($controller->isNotWritable())379				->then380					->boolean($controller->stream_open(uniqid(), 'a', 0))->isFalse()381					->array($controller->getCalls())->isNotEmpty()382					->boolean($controller->stream_open(uniqid(), 'a+', 0))->isFalse()383				->if($controller = new testedClass(uniqid()))384				->if($controller->isWritable())385				->and($controller->isNotReadable())386				->then387					->boolean($controller->stream_open(uniqid(), 'a', 0))->isTrue()388					->array($controller->getCalls())->isNotEmpty()389					->boolean($controller->stream_open(uniqid(), 'a+', 0))->isFalse()390					->boolean($controller->stream_open(uniqid(), 'a+', STREAM_REPORT_ERRORS))->isFalse()391					->error('Permission denied', E_USER_WARNING)->exists()392			->assert('Use x and x+ mode')393				->if($controller = new testedClass(uniqid()))394				->then395					->boolean($controller->stream_open(uniqid(), 'x', 0))->isFalse()396					->array($controller->getCalls())->isNotEmpty()397					->boolean($controller->stream_open(uniqid(), 'x', STREAM_REPORT_ERRORS))->isFalse()398					->error('File exists', E_USER_WARNING)->exists()399					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isFalse()400					->boolean($controller->stream_open(uniqid(), 'x+', STREAM_REPORT_ERRORS))->isFalse()401					->error('File exists', E_USER_WARNING)->exists()402				->if($controller->notExists())403				->then404					->boolean($controller->stream_open(uniqid(), 'x', 0))->isTrue()405					->array($controller->getCalls())->isNotEmpty()406					->integer($controller->stream_tell())->isZero()407					->string($controller->stream_read(1))->isEmpty()408					->integer($controller->stream_write('a'))->isEqualTo(0)409					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isTrue()410					->integer($controller->stream_tell())->isZero()411					->string($controller->stream_read(1))->isEmpty()412					->integer($controller->stream_write('a'))->isEqualTo(1)413				->if($controller->setContents('abcdefghijklmnopqrstuvwxyz'))414				->then415					->boolean($controller->stream_open(uniqid(), 'x', 0))->isTrue()416					->array($controller->getCalls())->isNotEmpty()417					->integer($controller->stream_tell())->isZero()418					->string($controller->stream_read(1))->isEqualTo('a')419					->integer($controller->stream_write('a'))->isEqualTo(0)420					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isTrue()421					->integer($controller->stream_tell())->isZero()422					->string($controller->stream_read(1))->isEqualTo('a')423					->integer($controller->stream_write('a'))->isEqualTo(1)424				->if($controller->isNotReadable())425				->then426					->boolean($controller->stream_open(uniqid(), 'x', 0))->isFalse()427					->array($controller->getCalls())->isNotEmpty()428					->boolean($controller->stream_open(uniqid(), 'x', STREAM_REPORT_ERRORS))->isFalse()429					->error('Permission denied', E_USER_WARNING)->exists()430					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isFalse()431					->boolean($controller->stream_open(uniqid(), 'x+', STREAM_REPORT_ERRORS))->isFalse()432					->error('Permission denied', E_USER_WARNING)->exists()433				->if($controller->isReadable())434				->and($controller->isNotWritable())435				->then436					->boolean($controller->stream_open(uniqid(), 'x', 0))->isTrue()437					->array($controller->getCalls())->isNotEmpty()438					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isFalse()439					->boolean($controller->stream_open(uniqid(), 'x+', STREAM_REPORT_ERRORS))->isFalse()440					->error('Permission denied', E_USER_WARNING)->exists()441				->if($controller->stream_open = false)442				->then443					->boolean($controller->stream_open(uniqid(), 'x', 0))->isFalse()444					->boolean($controller->stream_open(uniqid(), 'x+', 0))->isFalse()445					->boolean($controller->stream_open(uniqid(), 'x+', STREAM_REPORT_ERRORS))->isFalse()446					->error('Permission denied', E_USER_WARNING)->notExists()447		;448	}449	public function testStreamSeek()450	{451		$this452			->if($controller = new testedClass(uniqid()))453			->then454				->boolean($controller->stream_seek(0))->isTrue()455				->boolean($controller->stream_seek(1))->isTrue()456			->if($controller->contains('abcdefghijklmnopqrstuvwxyz'))457			->and($controller->stream_open(uniqid(), 'r', 0))458			->then459				->boolean($controller->stream_seek(0))->isTrue()460				->boolean($controller->stream_seek(1))->isTrue()461				->string($controller->stream_read(1))->isEqualTo('b')462				->boolean($controller->stream_seek(25))->isTrue()463				->string($controller->stream_read(1))->isEqualTo('z')464				->boolean($controller->stream_seek(26))->isTrue()465				->string($controller->stream_read(1))->isEmpty()466				->boolean($controller->stream_seek(0))->isTrue()467				->string($controller->stream_read(1))->isEqualTo('a')468				->boolean($controller->stream_seek(-1, SEEK_END))->isTrue()469				->string($controller->stream_read(1))->isEqualTo('z')470				->boolean($controller->stream_seek(-26, SEEK_END))->isTrue()471				->string($controller->stream_read(1))->isEqualTo('a')472				->boolean($controller->stream_seek(-27, SEEK_END))->isTrue()473				->string($controller->stream_read(1))->isEmpty()474			->if($controller = new testedClass(uniqid()))475			->and($controller->contains('abcdefghijklmnopqrstuvwxyz'))476			->and($controller->stream_open(uniqid(), 'r', 0))477			->and($controller->stream_read(4096))478			->then479				->boolean($controller->stream_eof())->isTrue()480				->boolean($controller->stream_seek(0))->isTrue()481				->boolean($controller->stream_eof())->isFalse()482		;483	}484	public function testStreamEof()485	{486		$this487			->if($controller = new testedClass(uniqid()))488			->then489				->boolean($controller->stream_eof())->isFalse()490			->if($controller->contains('abcdefghijklmnopqrstuvwxyz'))491			->then492				->boolean($controller->stream_eof())->isFalse()493			->if($controller->stream_seek(26))494			->then495				->boolean($controller->stream_eof())->isFalse()496			->if($controller->stream_seek(27))497			->then498				->boolean($controller->stream_eof())->isFalse()499			->if($controller->stream_open(uniqid(), 'r', 0))500			->and($controller->stream_seek(27))501			->and($controller->stream_read(1))502			->then503				->boolean($controller->stream_eof())->isTrue()504		;505	}506	public function testStreamTell()507	{508		$this509			->if($controller = new testedClass(uniqid()))510			->then511				->integer($controller->stream_tell())->isZero()512			->if($controller->stream_seek($offset = rand(1, 4096)))513			->then514				->integer($controller->stream_tell())->isEqualTo($offset)515		;516	}517	public function testStreamRead()518	{519		$this520			->if($controller = new testedClass(uniqid()))521			->and($controller->stream_open(uniqid(), 'r', 0))522			->then523				->string($controller->stream_read(1))->isEmpty()524				->boolean($controller->stream_eof())->isTrue()525			->if($controller->contains('abcdefghijklmnopqrstuvwxyz'))526			->then527				->string($controller->stream_read(1))->isEqualTo('a')528				->boolean($controller->stream_eof())->isFalse()529			->if($controller->stream_seek(6))530			->then531				->string($controller->stream_read(1))->isEqualTo('g')532				->string($controller->stream_read(4096))->isEqualTo('hijklmnopqrstuvwxyz')533				->boolean($controller->stream_eof())->isTrue()534				->string($controller->stream_read(1))->isEmpty()535		;536	}537	public function testStreamWrite()538	{539		$this540			->if($controller = new testedClass(uniqid()))541			->then542				->integer($controller->stream_write('a'))->isZero()543				->integer($controller->stream_tell())->isZero()544			->if($controller->stream_open(uniqid(), 'r', 0))545			->then546				->integer($controller->stream_write('a'))->isZero()547				->integer($controller->stream_tell())->isZero()548			->if($controller->stream_open(uniqid(), 'w', 0))...

Connection.php

Source:Connection.php

1<?php2/**3 * @author    Philip Bergman <pbergman@live.nl>4 * @copyright Philip Bergman5 */6namespace PBergman\Bundle\BeanstalkBundle\Server;7use PBergman\Bundle\BeanstalkBundle\BeanstalkEvents;8use PBergman\Bundle\BeanstalkBundle\Event\StreamReadEvent;9use PBergman\Bundle\BeanstalkBundle\Event\StreamWriteEvent;10use PBergman\Bundle\BeanstalkBundle\Exception\ConnectionException;11use PBergman\Bundle\BeanstalkBundle\Socket\SocketWrapper;12use Symfony\Component\EventDispatcher\EventDispatcherInterface;13class Connection extends SocketWrapper implements ConnectionInterface14{15    /** @var EventDispatcherInterface  */16    protected $dispatcher;17    /**18     * @param   Configuration $config19     * @throws  ConnectionException20     */21    function __construct(Configuration $config = null)22    {23        if ($config instanceof Configuration) {24            return parent::open(25                $config->getHost(),26                $config->getPort(),27                $config->getTimeout(),28                $config->isPersistent()29            );30        }31        parent::__construct();32    }33    /**34     * @param   $socket35     * @return  $this36     */37    public function setSocket($socket)38    {39        parent::__construct($socket);40        return $this;41    }42    /**43     * return timestamp, a unix timestamp with dot and micrtime as suffix44     *45     * @return string46     */47    protected function getTimeStamp()48    {49        $utime = microtime(true);50        return (new \DateTime(date(sprintf('Y-m-d H:i:s.%06d', ($utime - floor($utime)) * 1000000), $utime)))->format('U.u');51    }52    /**53     * @inheritdoc54     */55    public function write($data, $length = null)56    {57        if (!is_null($this->dispatcher) && $this->dispatcher->hasListeners(BeanstalkEvents::STREAM_WRITE)) {58            $this->dispatcher->dispatch(59                BeanstalkEvents::STREAM_WRITE,60                new StreamWriteEvent(61                    is_null($length) ? $data : substr($data, 0, $length),62                    $this->getTimeStamp()63                )64            );65        }66        return parent::write($data, $length);67    }68    /**69     * @@inheritdoc70     */71    public function read($length)72    {73        $read = parent::read($length);74        if (!is_null($this->dispatcher) && $this->dispatcher->hasListeners(BeanstalkEvents::STREAM_READ)) {75            $this->dispatcher->dispatch(76                BeanstalkEvents::STREAM_READ,77                new StreamReadEvent($read, $this->getTimeStamp())78            );79        }80        return $read;81    }82    /**83     * @@inheritdoc84     */85    public function readLine()86    {87        $read = parent::readLine();88        if (!is_null($this->dispatcher) && $this->dispatcher->hasListeners(BeanstalkEvents::STREAM_READ)) {89            $this->dispatcher->dispatch(90                BeanstalkEvents::STREAM_READ,91                new StreamReadEvent($read, $this->getTimeStamp())92            );93        }94        return $read;95    }96    /**97     * @param   EventDispatcherInterface $dispatcher98     * @return  $this99     */100    public function setDispatcher(EventDispatcherInterface $dispatcher)101    {102        $this->dispatcher = $dispatcher;103        return $this;104    }105    /**106     * @return bool107     */108    public function hasDispatcher()109    {110        return !is_null($this->dispatcher);111    }112}...

Rcon.php

Source:Rcon.php

...114	115	private static function Receive()116	{117		$response = '';118		$stream_read = '';119		120		while (socket_recv(self::$socket, $stream_read, 4096, 0) !== false)121		{122			$response .= $stream_read;123		}124		125		socket_clear_error(self::$socket);126		127		return $response;128	}129}130?>...

stream_read

Using AI Code Generation

1fwrite($handle, "Hello World!");2rewind($handle);3echo stream_get_contents($handle);4fclose($handle);5fwrite($handle, "Hello World!");6rewind($handle);7echo stream_get_contents($handle);8fclose($handle);9fwrite($handle, "Hello World!");10rewind($handle);11echo stream_get_contents($handle);12fclose($handle);13fwrite($handle, "Hello World!");14rewind($handle);15echo stream_get_contents($handle);16fclose($handle);17fwrite($handle, "Hello World!");18rewind($handle);19echo stream_get_contents($handle);20fclose($handle);21fwrite($handle, "Hello World!");22rewind($handle);23echo stream_get_contents($handle);24fclose($handle);25fwrite($handle, "Hello World!");26rewind($handle);27echo stream_get_contents($handle);28fclose($handle);29fwrite($handle, "Hello World!");30rewind($handle);31echo stream_get_contents($handle);32fclose($handle);33fwrite($handle, "Hello World!");34rewind($handle);35echo stream_get_contents($handle);36fclose($handle);

stream_read

Using AI Code Generation

1$fp = fopen("1.php", "r");2$has = new hash();3$has->stream_read($fp);4fclose($fp);5$fp = fopen("1.php", "r");6$has = new hash();7$has->stream_read($fp);8fclose($fp);9$fp = fopen("1.php", "r");10$has = new hash();11$has->stream_read($fp);12fclose($fp);13$fp = fopen("1.php", "r");14$has = new hash();15$has->stream_read($fp);16fclose($fp);17$fp = fopen("1.php", "r");18$has = new hash();19$has->stream_read($fp);20fclose($fp);21$fp = fopen("1.php", "r");22$has = new hash();23$has->stream_read($fp);24fclose($fp);25$fp = fopen("1.php", "r");26$has = new hash();27$has->stream_read($fp);28fclose($fp);29$fp = fopen("1.php", "r");30$has = new hash();31$has->stream_read($fp);32fclose($fp);33$fp = fopen("1.php", "r");34$has = new hash();35$has->stream_read($fp);36fclose($fp);37$fp = fopen("1.php", "r");38$has = new hash();39$has->stream_read($fp);40fclose($fp);41$fp = fopen("1.php", "r");42$has = new hash();43$has->stream_read($fp);44fclose($fp

stream_read

Using AI Code Generation

1$fp=fopen("file.txt","r");2$file_size=filesize("file.txt");3$data=fread($fp,$file_size);4fclose($fp);5echo $data;6Related Posts: PHP | stream_get_contents() Function7PHP | stream_get_line() Function8PHP | stream_get_meta_data() Function9PHP | stream_get_wrappers() Function10PHP | stream_set_blocking() Function11PHP | stream_set_timeout() Function12PHP | stream_set_write_buffer() Function13PHP | stream_socket_client() Function14PHP | stream_socket_enable_crypto() Function15PHP | stream_socket_get_name() Function16PHP | stream_socket_pair() Function17PHP | stream_socket_recvfrom() Function18PHP | stream_socket_sendto() Function19PHP | stream_socket_server() Function20PHP | stream_socket_shutdown() Function21PHP | stream_supports_lock() Function22PHP | stream_wrapper_register() Function23PHP | stream_wrapper_restore() Function24PHP | stream_wrapper_unregister() Function25PHP | stream_wrapper_unregister() Function26PHP | stream_context_create() Function27PHP | stream_context_get_default() Function28PHP | stream_context_get_options() Function29PHP | stream_context_set_default() Function30PHP | stream_context_set_option() Function31PHP | stream_context_set_params() Function32PHP | stream_copy_to_stream() Function33PHP | stream_encoding() Function34PHP | stream_filter_append() Function35PHP | stream_filter_prepend() Function36PHP | stream_filter_register() Function37PHP | stream_filter_remove() Function38PHP | stream_get_filters() Function39PHP | stream_get_line() Function40PHP | stream_get_meta_data() Function41PHP | stream_get_transports() Function42PHP | stream_get_wrappers() Function43PHP | stream_is_local() Function44PHP | stream_resolve_include_path() Function45PHP | stream_select() Function46PHP | stream_set_blocking() Function47PHP | stream_set_timeout() Function48PHP | stream_set_write_buffer() Function49PHP | stream_socket_accept() Function50PHP | stream_socket_client() Function51PHP | stream_socket_enable_crypto() Function52PHP | stream_socket_get_name() Function53PHP | stream_socket_pair() Function

stream_read

Using AI Code Generation

1$fp = fopen("1.php", "r");2echo stream_get_contents($fp);3fclose($fp);4stream_get_contents(stream, max_length, offset)5Recommended Posts: PHP | stream_set_chunk_size() Function6PHP | stream_get_meta_data() Function7PHP | stream_set_write_buffer() Function8PHP | stream_set_read_buffer() Function9PHP | stream_get_line() Function10PHP | stream_set_blocking() Function11PHP | stream_copy_to_stream() Function12PHP | stream_set_timeout() Function13PHP | stream_get_wrappers() Function14PHP | stream_set_write_buffer() Function15PHP | stream_get_filters() Function16PHP | stream_set_chunk_size() Function17PHP | stream_get_meta_data() Function18PHP | stream_set_write_buffer() Function19PHP | stream_get_line() Function20PHP | stream_set_blocking() Function21PHP | stream_copy_to_stream() Function22PHP | stream_set_timeout() Function23PHP | stream_get_wrappers() Function24PHP | stream_set_write_buffer() Function25PHP | stream_get_filters() Function26PHP | stream_set_chunk_size() Function27PHP | stream_get_meta_data() Function28PHP | stream_set_write_buffer() Function29PHP | stream_get_line() Function30PHP | stream_set_blocking() Function31PHP | stream_copy_to_stream() Function32PHP | stream_set_timeout() Function33PHP | stream_get_wrappers() Function34PHP | stream_set_write_buffer() Function35PHP | stream_get_filters() Function36PHP | stream_set_chunk_size() Function37PHP | stream_get_meta_data() Function38PHP | stream_set_write_buffer() Function39PHP | stream_get_line() Function40PHP | stream_set_blocking() Function41PHP | stream_copy_to_stream()

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.