danog/parallel
1
0
Fork 0
mirror of https://github.com/danog/parallel.git synced 2025-01-22 14:01:14 +01:00
Code Issues Projects Releases Wiki Activity

Update ChannelTest to match changes in Channel

Browse Source
This commit is contained in:
coderstephen 2015-08-27 13:07:56 -05:00
parent 97c7af4d66
commit 9112f671a5
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/Sync/ChannelTest.php
View File

@ -4,6 +4,7 @@ namespace Icicle\Tests\Concurrent\Sync;
use Icicle\Concurrent\Sync\Channel;
use Icicle\Coroutine;
use Icicle\Loop;
use Icicle\Socket\Stream\DuplexStream;
use Icicle\Tests\Concurrent\TestCase;
class ChannelTest extends TestCase
@ -19,8 +20,8 @@ class ChannelTest extends TestCase
public function testClose()
{
list($a, $b) = Channel::createSocketPair();
$a = new Channel($a);
$b = new Channel($b);
$a = new Channel(new DuplexStream($a));
$b = new Channel(new DuplexStream($b));
// Close $a. $b should close on next read...
$a->close();
@ -36,13 +37,13 @@ class ChannelTest extends TestCase
{
Coroutine\create(function () {
list($a, $b) = Channel::createSocketPair();
$a = new Channel($a);
$b = new Channel($b);
$a = new Channel(new DuplexStream($a));
$b = new Channel(new DuplexStream($b));
yield $a->send('hello');
$data = (yield $b->receive());
$this->assertEquals('hello', $data);
});
})->done();
Loop\run();
}
@ -53,15 +54,14 @@ class ChannelTest extends TestCase
public function testThreadTransfer()
{
list($a, $b) = Channel::createSocketPair();
$a = new Channel($a);
$b = new Channel($b);
$b = new Channel(new DuplexStream($b));
$thread = \Thread::from(function () {
$a = $this->a;
$a = new Channel(new DuplexStream($this->a));
});
$thread->a; // <-- Transfer channel $a to the thread
$thread->start(PTHREADS_INHERIT_INI);
$thread->a = $a; // <-- Transfer channel $a to the thread
$thread->start();
$thread->join();
}
}