8 $s = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, 0);
9 array_map(fn($s)=>stream_set_blocking($s,false), $s);
11 $w = new ion\Writer\Stream\Writer($s[0]);
12 $w->startLob(ion\Type::CLob);
13 $w->appendLob(str_repeat("a", 0x1000));
16 $r = new ion\Reader\Stream\Reader($s[1]);
17 for ($i = 0; $i < 10; $i++) {
19 for ($R=[$s[1]]; stream_select($R, $W, $E, 0); ) {
20 if ($r->getType() != ion\Type::CLob)
27 $w->appendLob(str_repeat("a", 0x1000));
33 while ($r->readLobPart($b)) {
40 var_dump($r->key(), $l);