Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

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.