Stream
事件驱动的可读流和可写流，用于 ReactPHP 中的非阻塞I/O
为了使 EventLoop 更容易使用，该组件引入了强大的“流”概念。 流允许您以小块的方式高效地处理大量数据(比如一个多GB的文件下载)，而不必一次将所有数据存储在内存中。 与PHP中的流非常相似，但有一个更适合异步、非阻塞I/O的接口。
目录
stream用法
ReactPHP在其整个生态系统中使用“流”的概念，为处理任意数据内容和大小的流提供一致的高级抽象。 虽然流本身是一个非常底层的概念，但它可以作为一个强大的抽象来构建更高级的组件和协议。 如果你不熟悉这个概念，可以把它们想象成水管(pipe): 你可以从一个水源中取水，也可以产生水并将其输送到任何目的地水槽(sink)。
同样，流可以是
- 可读(如
STDIN终端输入)或 - 可写(如
STDOUT终端输出)或 - 双工(既可读又可写，例如TCP/IP连接)
因此，这个包定义了以下三个接口
ReadableStreamInterface
ReadableStreamInterface 负责为只读流和双工流的可读端。
除了定义一些方法之外，这个接口还实现了EventEmitterInterface允许你对特定的事件做出响应。
事件回调函数必须是一个有效的 callable ，遵守严格的参数定义，并且必须完全按照文档中描述的那样接受事件参数。
事件回调函数绝不能抛出Exception。
事件回调函数的返回值将被忽略，并且没有任何效果，因此出于性能原因，建议您不要返回任何过多的数据结构。
这个接口的每个实现都必须遵循这些事件语义，才能被认为是合法的流。
请注意，此接口的高级实现可能会选择使用专用语义来定义附加事件， 这些专用语义未定义为此低级流规范的一部分。 与这些事件语义的一致性超出了此接口的范围， 因此您可能还必须参考此类更高级别实现的文档。
data事件
当从该源流读取/接收数据时，将触发data事件。事件接收传入数据的单个混合参数。
$stream->on('data', function ($data) {
echo $data;
});
该事件可能被触发任意次，如果该流根本不发送任何数据，则可能为零次。
在end或close事件之后不应该触发它。
$data参数可能是混合类型，但通常建议它应该是string值，
或者可以使用允许表示为string的类型，以实现最大的兼容性。
许多常见流(如TCP/IP连接或基于文件的流)将发出原始(二进制)有效负载数据，
这些数据通过网络接收为string值块。
由于这种基于流的特性，发送方可以发送任意数量不同大小的块。 不能保证接收到的数据块与发送方打算发送的帧完全相同。 换句话说，许多底层协议(如TCP/IP)以块的形式传输数据， 这些块可能介于单字节到几十千字节之间。 为了实现正确的消息帧，您可能需要对这些数据块应用更高级别的协议。
end事件
源流成功到达流尾(EOF)后，将触发end事件。
$stream->on('end', function () {
echo 'END';
});
该事件最多触发一次，或者根本不触发，这取决于是否检测到成功结束。
它不应该在前一个end或close事件之后触发。
如果流未成功结束而关闭（例如在前一个close事件之后），则不能触发该事件。
流结束后，必须切换到不可读模式，另请参见isReadable()
只有成功到达end时才会触发此事件，如果流被不可恢复的错误中断或显式关闭则不会触发此事件。 并不是所有的流都知道“成功的结束”这个概念。
许多用例涉及检测流何时关闭(终止)，在这种情况下，您应该使用close事件。
流发出end事件后，通常应该跟在close事件后面。
如果远程端关闭连接或成功读取文件句柄直到其结束(EOF)，许多公共流（如TCP/IP连接或基于文件的流）都将发出此事件。
请注意，不应将此事件与end()方法混淆。
此事件定义从源流读取的成功结束，而end()方法定义向目标流写入的成功结束。
error事件
通常是在尝试从该流读取时发生致命错误，则会触发error事件。
事件为错误实例接收一个Exception参数。
$server->on('error', function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
});
一旦流检测到致命错误（如致命的传输错误）或意外的data或过早的end事件之后，就会触发此事件。
它不应在前一个error, end 或 close事件之后触发。
如果这不是致命的错误情况，例如没有导致任何数据丢失的临时网络问题，则不会触此事件。
出现流错误后，它必须关闭流，因此后面应该有一个close事件，
然后切换到不可读模式，另请参见close()和isReadable()。
许多常见的流（例如TCP/IP连接或基于文件的流）只处理数据传输，
并不对数据边界进行假设（例如意外的data或过早的end事件）。
换言之，许多较底层的协议（例如TCP/IP）可能会选择只在出现致命传输错误时触发事件，并在响应时关闭(终止)流。
如果这个流是DuplexStreamInterface，你也应该注意到流的可写端也实现了error事件。
换句话说，在读取或写入流时可能发生错误，这应该导致相同的错误处理。
close事件
一旦流关闭（终止），将触发close事件。
$stream->on('close', function () {
echo 'CLOSED';
});
根据流是否终止，这个事件应该被触发一次，或者根本不触发。
它不应该在前一个close事件之后触发。
流关闭后，必须切换到不可读模式，
另请参见isReadable()。
与end事件不同，每当流关闭时都应触发此事件，而不管此事件是由于不可恢复的错误隐式发生的，还是在任何一方关闭流时显式发生的。
如果只想检测成功结束，则应改用end事件。
许多常见的流（例如TCP / IP连接或基于文件的流）很可能在读取成功结束事件或致命的传输错误事件之后选择触发此事件。
如果此流是DuplexStreamInterface，则您还应该注意该流的可写端close事件的实现。
换句话说，在接收到该事件之后，流必须切换到不可写和不可读取模式，另请参见 isWritable()。
注意，该事件不应与end事件混淆。
isReadable()
isReadable(): bool方法可用于检查此流是否处于可读状态（尚未关闭）。
此方法可用于检查流是否仍然接受传入的数据事件，或者它是否已结束或关闭。
一旦流不可读，就不再发出data或end事件。
assert($stream->isReadable() === false);
$stream->on('data', assertNeverCalled());
$stream->on('end', assertNeverCalled());
成功打开的流始终必须以可读模式启动。
一旦流结束或关闭，它必须切换到非可读模式。
这可以随时发生，通过close()显式地发生，或者由于远程关闭或不可恢复的传输错误而隐式地发生。
流一旦切换到非可读模式，就绝不能回到可读模式。
如果此流是DuplexStreamInterface，则您还应该注意该流的可写端isWritable()方法的实现。
除非这是一个半开双工流，否则它们通常应该具有相同的返回值。
pause()
pause(): void方法可用于暂停读取传入的数据事件。
从事件循环中删除数据源文件描述符。 这使您可以限制传入的数据。
除非另有说明，否则成功打开的流不应暂停。
流暂停后，就不应再触发data或end事件
$stream->pause();
$stream->on('data', assertShouldNeverCalled());
$stream->on('end', assertShouldNeverCalled());
该方法仅是建议性的，通常不建议调用，但该流可以继续emit(发出)data事件。
您可以通过再次调用resume()来继续处理事件。
注意，这两种方法都可以被调用多次，多次调用pause()无效。
另见resume()
resume()
resume(): void 方法可用于恢复data事件。
在pause()之后重新连接数据源。
$stream->pause();
$loop->addTimer(1.0, function () use ($stream) {
$stream->resume();
});
请注意，这两个方法都可以被调用任意次数，在没有pause()的情况下调用resume()无效。
请参见pause()
pipe()
pipe(WritableStreamInterface $dest, array $options = []) 方法可将此可读源中的所有数据通过管道传输到设定的可写目标源。
自动将所有传入数据发送到目标源。根据目标源可以处理的内容自动限制源。
$source->pipe($dest);
同样，您也可以通过管道将实现DuplexStreamInterface的实例导入自身，以便回写接收到的所有数据。
对于TCP/IP echo服务，这是一个有用的特性:
$connection->pipe($connection);
这个方法按原样返回目标流，可以用来建立管道流链:
$source->pipe($decodeGzip)->pipe($filterBadWords)->pipe($dest);
默认情况下，一旦源流发出end()事件，就会对目标流调用end()。可以这样禁用:
$source->pipe($dest, array('end' => false));
请注意，这只适用于end事件。
如果源流上发生 error 或显式close事件，则您必须手动关闭目标流:
$source->pipe($dest);
$source->on('close', function () use ($dest) {
$dest->end('BYE!');
});
如果源流不可读（关闭状态），则这是不可操作的。
$source->close();
$source->pipe($dest); // 禁止操作
如果目标流不可写（关闭状态），则这将简单地限制（暂停）源流:
$dest->close();
$source->pipe($dest); // calls $source->pause()
同样，如果目标流在管道仍处于活动状态时关闭，它还将限制（暂停）源流:
$source->pipe($dest);
$dest->close(); // calls $source->pause()
一旦管道成功设置，目标流必须发出一个pipe事件，源流必须有一个 event 参数。
close()
close(): void 方法可以用来关闭流(强制)。
$stream->close();
一旦流被关闭，它应该触发一个close事件。
请注意，此事件不应触发多次。
调用此方法后，流必须切换到不可读模式，另请参见isReadable()。
这意味着不应再触发data或end事件。
$stream->close();
assert($stream->isReadable() === false);
$stream->on('data', assertNeverCalled());
$stream->on('end', assertNeverCalled());
如果此流是DuplexStreamInterface，则还应该注意流的可写端close()方法的实现。
换句话说，调用此方法后，流必须切换到不可写和不可读模式，另请参见iswriteable()。
请注意，此方法不应与end()方法混淆。
WritableStreamInterface
WritableStreamInterface 为只写流和双工流的可写端接口。
除了定义一些方法外，这个接口还实现了EventEmitterInterface，它允许您对某些事件做出反应。
事件回调函数必须是一个有效的callable，它遵循严格的参数定义，并且必须完全按照文档所示接受事件参数。
事件回调函数不能抛出Exception。
事件回调函数的返回值将被忽略并且没有任何影响，因此出于性能原因，建议您不要返回任何过多的数据结构。
此接口的每个实现都必须遵循这些事件语义，才能被视为合法的流。
请注意，此接口的更高级别的实现可以选择使用未定义为该底层级别流规范一部分的专用语义来定义其他事件。 与这些事件语义的一致性超出了此接口的范围，因此您可能还必须参考此类更高级别的实现的文档。
drain事件
每写入缓冲区满时且有更多数据到达时，就会发出drain事件。
$stream->on('drain', function () use ($stream) {
echo 'Stream is now ready to accept more data';
});
每写入缓冲区满时且有更多数据到达时，就会发出drain事件。
换句话说，这个事件可以被触发多次，如果缓冲区不满，则该事件可能是零次。
如果缓冲区不满，则不应触发此事件。
该事件主要在内部使用，有关更多详细信息，请参见write()
pipe事件
当一个可读流pipe()进入数据时，pipe事件将被触发。
事件接收源流的一个ReadableStreamInterface参数。
$stream->on('pipe', function (ReadableStreamInterface $source) use ($stream) {
echo 'Now receiving piped data';
// explicitly close target if source emits an error
$source->on('error', function () use ($stream) {
$stream->close();
});
});
$source->pipe($stream);
对于每个成功导入目标流的可读流，此事件必须触发一次。
换句话说，这个事件可以被触发多次，如果没有数据流通过管道进入这个流，则可能是零次。
如果源不可读(已经关闭)或目标不可写(已经关闭)，则绝不能触发此事件。
此事件主要在内部使用，请参阅pipe()了解更多细节。
error 事件
一旦发生致命错误，则会触发error事件，通常是在试图写入该流时。
事件为错误实例接收一个Exception对象参数。
$stream->on('error', function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
});
一旦流检测到致命错误(例如致命传输错误)，就会触发此事件。
它不应该在前一个error 或 close事件之后触发。
如果不出现一个致命的错误情况，例如没有导致任何数据丢失的临时网络问题，则不会触发。
在流出错后，它必须关闭流，因此应该紧跟着一个close事件，然后切换到非可写模式，参见close()和isWritable()。
许多常见流（例如TCP / IP连接或基于文件的流）仅处理数据传输，并且可能会选择仅针对致命的传输错误触发一次，然后将其关闭（终止）作为响应。
如果这个流是一个DuplexStreamInterface，您还应该注意流的可读端error事件的实现。
换句话说，在读取或写入流时可能发生错误，这将导致相同的错误处理。
close 事件
一旦流关闭（终止），将发出close事件。
$stream->on('close', function () {
echo 'CLOSED';
});
根据流是否终止，此事件应触发一次或从不触发。
它不会在前一个close事件之后触发。
流关闭后，必须切换到不可写模式，
另请参见isWritable()
无论是由于不可恢复的错误而隐式触发还是在任何一方关闭流时显式触发，只要流关闭，都应触发此事件。
许多常见的流(例如TCP/IP连接或基于文件的流)可能会选择在end()方法刷新缓冲区后、在接收到成功 end 事件或致命的传输error事件后触发此事件。
如果此流是DuplexStreamInterface，则还应注意该流的可读端close事件的实现。
换句话说，接收到该事件后，流必须切换到不可写和不可读取模式，另请参见isReadable()。
注意，该事件不应与end事件混淆。
isWritable()
isWritable(): bool方法可用于检查此流是否处于可写状态（尚未关闭）。
此方法可用于检查流是否仍接受写入数据，或者是否已结束或关闭。 将数据写入不可写流是不可操作的:
assert($stream->isWritable() === false);
$stream->write('end'); // NO-OP
$stream->end('end'); // NO-OP
成功打开的流必须始终以可写模式。
一旦流结束或关闭，它必须切换到不可写模式。
这种情况随时可能发生，可以通过end()或close()显式发生，也可以由于远程关闭或不可恢复的传输错误而隐式发生。
一旦流切换到不可写模式，它就不能转换回可写模式。
如果此流是DuplexStreamInterface实现，则还应该注意流的可读端isReadable()方法的实现。除非这是半开放双工流，否则它们通常应该具有相同的返回值。
write()
使用write(mixed $data): bool方法将数据写入流。
必须使用布尔值true来确认成功写入，这意味着要么立即写入（刷新）数据，要么对数据进行缓冲和调度以备将来写入。
请注意，这个接口无法控制显式刷新缓冲数据，因为寻找合适的刷新时间超出了这个接口的范围，要由这个接口的实现来决定。
许多常见的流（例如TCP / IP连接或基于文件的流）可以选择缓冲所有数据，并通过使用底层的EventLoop来检查资源何时实际可写来计划将来的刷新。
如果流不能处理写入（或刷新）数据的操作，它应该发出一个error事件，如果流不能从这个错误中恢复，则可能close()该流。
如果在添加$data后内部缓冲区已满，那么write()应该返回false，表明调用者应该停止发送数据，直到缓冲区耗尽。
一旦缓冲区准备好接受更多数据，流应该发送drain事件。
同样，如果流是不可写的(已经处于关闭状态)，它一定不能处理设定的$data，并且应该返回false，表明调用者应该停止发送数据。
$data参数可能是混合类型，但通常建议它应该是一个string值，或者使用允许转化为string的类型，以最大限度地兼容。
许多常见的流（例如TCP / IP连接或基于文件的流）仅接受原始（二进制）有效载荷数据，这些数据通过网络作为string值的块传输。
由于这种基于流的特性，发送方可以发送任意数量大小不同的块。无法保证这些数据块将以发送方打算发送的完全相同的顺序接收。
换言之，许多较底层的协议（如TCP/IP）以块的形式传输数据，这些块的大小可能介于单个字节到几十千字节之间。 您需要对这些数据块应用更高级的协议，以便实现正确的消息帧。
end()
end(mixed $data = null): void方法可用于成功结束流（可选地发送一些最终数据）。
这个方法可以用来成功地结束流，例如，在发送出所有当前缓存的数据后关闭流。
$stream->write('hello');
$stream->write('world');
$stream->end();
如果当前没有缓冲的数据，也没有需要刷新的数据，那么这个方法可以立即close()流。
如果缓冲区中仍有需要首先刷新的数据，则该方法应该尝试写出这些数据，然后才使用close()关闭流。
一旦流关闭，它会触发close事件。
请注意，这个接口无法控制显式刷新缓冲数据，因为寻找合适的刷新时间超出了这个接口的范围，要由这个接口的实现来决定。
许多常见的流（例如TCP / IP连接或基于文件的流）可以选择缓冲所有数据，并通过使用底层的EventLoop来检查资源何时实际可写来计划将来的刷新。
您可以选择在结束流之前将一些最终数据传递给流。 如果将非null值指定为$data，则此方法的行为就像在没有结束之前调用write($data)一样。
// shorter version
$stream->end('bye');
// same as longer version
$stream->write('bye');
$stream->end();
调用此方法后，流必须切换到不可写模式，另请参见isWritable()。
这意味着不可能再进行写操作，因此任何其他的write()或end()调用均无效。
$stream->end();
assert($stream->isWritable() === false);
$stream->write('nope'); // NO-OP
$stream->end(); // NO-OP
如果此流是DuplexStreamInterface实现，则调用此方法也应结束其可读端，除非该流支持半开模式。
换句话说，调用此方法后，这些流应该切换到不可写和不可读取的模式，另请参见isReadable()
这意味着在这种情况下，流不再应该发出任何data或end事件。
流可能会选择使用pause()方法逻辑，但必须特别注意确保对resume()方法的后续调用不应继续发出可读事件。
注意，该方法不应与close()方法混淆。
close()
close(): void 方法可用于（强制）关闭流。
此方法可用于强制关闭流，即在不等待刷新任何缓冲数据的情况下关闭流。 如果缓冲区中仍有数据，则会丢弃此数据。
$stream->close();
一旦流关闭，它应该发出一个close事件。
请注意，不应多次触发此事件。
调用此方法后，流必须切换到不可写模式，另请参见isWritable()。
这意味着不可能再进行写操作，因此任何其他的write()或end()调用均无效。
$stream->close();
assert($stream->isWritable() === false);
$stream->write('nope'); // NO-OP
$stream->end(); // NO-OP
注意，该方法不应与end()方法混淆。
与end()方法不同，此方法不处理任何现有缓冲区，而只是丢弃缓冲区内容。
同样，也可以在对流调用end()之后调用此方法，以停止等待流刷新其最终数据。
同样，为了停止等待流刷新其最终数据，也可以在流上调用end()之后调用此方法。
$stream->end();
$loop->addTimer(1.0, function () use ($stream) {
$stream->close();
});
如果此流是DuplexStreamInterface，则还应该注意流的可读端如何实现close() 方法。
换句话说，调用此方法后，流必须切换到不可写和不可读模式，另请参见isReadable()。
DuplexStreamInterface
DuplexStreamInterface为双工流（可读写）提供接口。
它建立在用于可读和可写流的现有接口之上，并遵循完全相同的方法和事件语义。
如果您是这个概念的新手，则应该先阅读ReadableStreamInterface和WritableStreamInterface。
除了定义一些方法外，该接口还实现了EventEmitterInterface，
它使您能够对ReadbleStreamInterface和WritableStreamInterface上定义的相同事件做出反应。
事件回调函数必须是一个有效的callable，遵守严格的参数定义，并且必须完全按照文档中描述接受事件参数。
事件回调函数绝不能抛出Exception。
事件回调函数的返回值将被忽略，并且没有任何效果，因此出于性能原因，建议您不要返回任何过多的数据结构。
这个接口的每个实现都必须遵循这些事件语义，才能被认为是合法流。
请注意，此接口的高级实现可能会选择使用专用语义来定义附加事件， 这些专用语义未定义为此低级流规范的一部分。 与这些事件语义的一致性超出了此接口的范围， 因此您可能还必须参考此类更高级别实现的文档。
另请参阅 ReadableStreamInterface和WritableStreamInterface。
Creating streams
ReactPHP在其整个生态系统中都使用
streams的概念，所以这个包的许多高级开发者只处理流使用。 流实例通常是在一些更高级别的组件中创建的，许多开发者实际上从来不需要处理创建流实例的问题。如果你想接受传入或建立传出的明文TCP/IP或安全TLS socket连接流，使用react/socket
如果你想接收一个http请求体流，请使用react/http
如果你想通过诸如STDIN, STDOUT, STDERR等进程管道与子进程通信，请使用react/child-process
如果你想对文件系统进行读写操作，请使用 react/filesystem
参见最后一章更多真实应用。
但是，如果您正在编写一个底层组件，或者想要从一个流资源创建一个流实例，那么下面的章节就是为您准备的。
请注意，以下示例使用
fopen()和stream_socket_client()只是为了说明。 这些函数不应该在真正的异步程序中使用，因为每个调用可能需要几秒钟才能完成，否则将阻塞EventLoop。 此外，fopen()调用将在某些平台上返回一个文件句柄，这可能是所有EventLoop实现所支持的，也可能不是。 作为一种替代方案，您可能希望使用上面列出的高级库。
ReadableResourceStream
ReadableResourceStream是PHP流资源ReadableStreamInterface的具体实现。
这可以用来表示只读资源，比如以可读模式打开的文件流，或者像STDIN这样的流:
$stream = new ReadableResourceStream(STDIN, $loop);
$stream->on('data', function ($chunk) {
echo $chunk;
});
$stream->on('end', function () {
echo 'END';
});
构造函数的第一个参数必须是一个以读取模式打开的有效的流资源(例如:fopen()的模式r)。
否则，它将抛出一个InvalidArgumentException:
// throws InvalidArgumentException
$stream = new ReadableResourceStream(false, $loop);
另请参阅DuplexResourceStream了解读写流资源。
该类内部试图在流资源上启用非阻塞模式，这可能不支持所有的流资源。
最值得注意的是，Windows上的管道(STDIN等)不支持这一点。
如果失败，它将抛出RuntimeException:
// throws RuntimeException on Windows
$stream = new ReadableResourceStream(STDIN, $loop);
一旦使用有效的流资源调用构造函数，该类将负责底层的流资源。
您应该只使用它的公共API，而不应该手动干扰底层的流资源。
该类接受一个可选参数int|null $readChunkSize，该参数控制一次从流中读取的最大缓冲区大小(以字节为单位)。
您可以在这里使用null值来应用其默认值。
除非您知道自己在做什么，否则不应该更改此值。
这可以是一个正数，这意味着一次最多可以从底层流资源读取X个字节。注意，如果流资源当前可用的字节数小于X字节，则实际读取的字节数可能更低。
这可以是-1，表示从底层流资源中读取所有可用的内容。
这应该读取直到流资源不再可读(即底层缓冲区耗尽)，注意这并不一定意味着它到达了EOF。
$stream = new ReadableResourceStream(STDIN, $loop, 8192);
PHP bug警告:如果PHP进程在没有
STDIN流的情况下显式启动， 那么尝试从STDIN读取数据可能会从其他流资源返回数据。 如果以空流(如php test.php < /dev/null而不是php test.php <&-)开始，则不会发生这种情况。 请参阅#81 了解更多细节。
WritableResourceStream
WritableResourceStream是PHP流资源的WritableStreamInterface的具体实现。
这可以用来表示只写的资源，比如以可写模式打开的文件流，或者像STDOUT或STDERR这样的流:
$stream = new WritableResourceStream(STDOUT, $loop);
$stream->write('hello!');
$stream->end();
构造函数的第一个参数必须是打开用于写入的有效流资源。
否则，它将抛出一个InvalidArgumentException:
// throws InvalidArgumentException
$stream = new WritableResourceStream(false, $loop);
另请参阅DuplexResourceStream了解读写流资源。
该类内部试图在流资源上启用非阻塞模式，这可能不支持所有的流资源。
最值得注意的是，Windows上的管道(STDOUT、STDERR等)不支持这一点。
如果失败，它将抛出RuntimeException:
// throws RuntimeException on Windows
$stream = new WritableResourceStream(STDOUT, $loop);
一旦使用有效的流资源调用构造函数，该类将负责底层的流资源。
您应该只使用它的公共API，而不应该手动干扰底层的流资源。
对这个类的任何write()调用都不会立即执行，而是在EventLoop报告流资源准备好接受数据后异步执行。
为此，它使用一个内存缓冲区字符串来收集所有未完成的写操作。
这个缓冲区应用了一个软限制，它定义了在调用者停止发送进一步数据之前，它愿意接受多少数据。
该类接受一个可选参数int|null $writeBufferSoftLimit，以字节为单位控制最大缓冲区大小。
您可以在这里使用null值来应用其默认值。
否则不应该更改此值，除非您知道自己在做什么。
$stream = new WritableResourceStream(STDOUT, $loop, 8192);
该类接受一个可选参数int|null $writeChunkSize，该参数以字节为单位控制一次写入流的最大缓冲区大小。
您可以在这里使用null值来应用其默认值。
除非您知道自己在做什么，否则不应该更改此值。
这可以是一个正数，这意味着一次最多将写入X个字节到底层流资源。注意，如果流资源当前可用的字节数小于X字节，则实际写入的字节数可能更低。
这可以是-1，意思是将所有可用的内容写入底层流资源。
$stream = new WritableResourceStream(STDOUT, $loop, null, 8192);
请参阅write()了解更多细节。
DuplexResourceStream
DuplexResourceStream是PHP流资源DuplexStreamInterface的具体实现。
用来表示读写资源，比如以读写模式打开的文件流，或者像TCP/IP连接这样的流:
$conn = stream_socket_client('tcp://google.com:80');
$stream = new DuplexResourceStream($conn, $loop);
$stream->write('hello!');
$stream->end();
请参阅DuplexStreamInterface 了解更多细节。
构造函数的第一个参数必须是一个有效的流资源，该流资源被打开用于读取和写入。
否则，它将抛出一个InvalidArgumentException:
// throws InvalidArgumentException
$stream = new DuplexResourceStream(false, $loop);
另请参阅只读的ReadableResourceStream和只写流资源的WritableResourceStream。
该类内部试图在流资源上启用非阻塞模式，这可能不支持所有的流资源。
最值得注意的是，Windows上的管道(STDOUT、STDERR等)不支持这一点。
如果失败，它将抛出RuntimeException:
// throws RuntimeException on Windows
$stream = new DuplexResourceStream(STDOUT, $loop);
一旦使用有效的流资源调用构造函数，该类将负责底层的流资源。
您应该只使用它的公共API，而不应该手动干扰底层的流资源。
该类接受一个可选参数int|null $readChunkSize，该参数控制一次从流中读取的最大缓冲区大小(以字节为单位)。
您可以在这里使用null值来应用其默认值。
除非您知道自己在做什么，否则不应该更改此值。
这可以是一个正数，这意味着一次最多可以从底层流资源读取X个字节。注意，如果流资源当前可用的字节数小于X字节，则实际读取的字节数可能更低。
这可以是-1，表示从底层流资源中读取所有可用的内容。
这应该读取直到流资源不再可读(即底层缓冲区耗尽)，注意这并不一定意味着它到达了EOF。
$conn = stream_socket_client('tcp://google.com:80');
$stream = new DuplexResourceStream($conn, $loop, 8192);
对这个类的任何write()调用都不会立即执行，而是在EventLoop报告流资源准备好接受数据后异步执行。
为此，它使用一个内存缓冲区字符串来收集所有未完成的写操作。
这个缓冲区应用了一个软限制，它定义了在调用者停止发送进一步数据之前，它愿意接受多少数据。
这个类接受另一个可选参数WritableStreamInterface|null $buffer，控制这个流的写行为。
您可以在这里使用null值来应用其默认值。
除非您知道自己在做什么，否则不应该更改此值。
如果你想改变写缓冲区软限制，你可以传递一个WritableResourceStream 的实例，像这样:
$conn = stream_socket_client('tcp://google.com:80');
$buffer = new WritableResourceStream($conn, $loop, 8192);
$stream = new DuplexResourceStream($conn, $loop, null, $buffer);
参见 WritableResourceStream 了解更多细节。
ThroughStream
ThroughStream实现了DuplexStreamInterface ，并将任何你写入它的数据传递到它的可读端。
$through = new ThroughStream();
$through->on('data', $this->expectCallableOnceWith('hello'));
$through->write('hello');
同样，end() 方法将结束流并触发end，然后close()流。
close() 方法 将关闭流并发出close.
相应地，这也可以像这样在pipe()上下文中使用:
$through = new ThroughStream();
$source->pipe($through)->pipe($dest);
可选，它的构造函数接受任何可调用的函数，然后这些函数将被用来 filter（过滤） 任何写入它的数据。 此函数在传递到可写端时接收单个数据参数，并且在传递到可读端时必须返回数据:
$through = new ThroughStream('strtoupper');
$source->pipe($through)->pipe($dest);
请注意，这个类不假设任何数据类型。这可用于转换数据，例如将任何结构化数据转换为换行符分隔的JSON（NDJSON）流，如下所示:
$through = new ThroughStream(function ($data) {
return json_encode($data) . PHP_EOL;
});
$through->on('data', $this->expectCallableOnceWith("[2, true]\n"));
$through->write(array(2, true));
允许回调函数抛出Exception。在这种情况下，流将发出一个error事件，然后close()流。
$through = new ThroughStream(function ($data) {
if (!is_string($data)) {
throw new \UnexpectedValueException('Only strings allowed');
}
return $data;
});
$through->on('error', $this->expectCallableOnce()));
$through->on('close', $this->expectCallableOnce()));
$through->on('data', $this->expectCallableNever()));
$through->write(2);
CompositeStream
CompositeStream实现了DuplexStreamInterface，
并可用于从两个分别实现ReadableStreamInterface和
WritableStreamInterface的单独流中创建一个双工流。
这对于一些可能需要单个DuplexStreamInterface 的api很有用，
或者只是因为像这样使用单个流实例通常更方便:
$stdin = new ReadableResourceStream(STDIN, $loop);
$stdout = new WritableResourceStream(STDOUT, $loop);
$stdio = new CompositeStream($stdin, $stdout);
$stdio->on('data', function ($chunk) use ($stdio) {
$stdio->write('You said: ' . $chunk);
});
这是一个合法流，它从底层流转发所有的流事件，并将所有的流调用转发给底层流。
如果你 write() 写入双工流，它将简单地将 write() 写入可写端并返回其状态。
如果end()双工流，则可写流将end()，可读流将pause()。
如果close()双工流，两个输入流都将被关闭。
如果两个输入流中的任何一个发出close事件，双工流也将关闭。
如果两个输入流中的任何一个在构造双工流时已经关闭，它将close()另一端并返回一个关闭的流。
用法
下面的例子可以用来将源文件的内容管道到目标文件中，而不必将整个文件读入内存:
$loop = new React\EventLoop\StreamSelectLoop;
$source = new React\Stream\ReadableResourceStream(fopen('source.txt', 'r'), $loop);
$dest = new React\Stream\WritableResourceStream(fopen('destination.txt', 'w'), $loop);
$source->pipe($dest);
$loop->run();
注意，这个例子使用
fopen()只是为了说明。 在真正的异步程序中不应该使用这种方法，因为文件系统本身就是阻塞的，而且每次调用都可能需要几秒钟的时间。 参见创建流获取更复杂的示例。
安装
推荐的安装这个库的方法是通过Composer。 Composer 新手?
该项目遵循SemVer ， 默认安装最新支持的版本:
$ composer require react/stream:^1.1.1
有关版本升级的详细信息，请参见CHANGELOG 。
该项目旨在在任何平台上运行，因此不需要任何PHP扩展，并支持通过 PHP 7+和HHVM在旧版PHP 5.3上运行。
强烈推荐在这个项目中使用PHP 7+。
测试
要运行测试套件，首先需要克隆这个存储库，然后安装所有依赖项通过Composer:
$ composer install
要运行测试套件，请转到项目根目录并运行:
$ php vendor/bin/phpunit
该测试套件还包含许多依赖稳定internet连接的功能集成测试。 如果您不想运行这些，则可以像这样跳过它们:
$ php vendor/bin/phpunit --exclude-group internet
License
MIT, see LICENSE file.
More
- 有关在实际应用程序中如何创建流的更多信息，请参见创建流。
- 请参阅我们的用户Wiki 和Packagist依赖项 在实际应用程序中使用流的软件包列表。