fn out_stream(in_stream: &Stream, messages_begin: StreamIndex) -> Stream {
    Stream::new(
        StreamIndexedQueue::with_begin(in_stream.signals_end()),
        messages_begin,
    )
}
/// Creates a matching outgoing stream for the given stream and slice begin
/// index.
Creates a matching outgoing stream for the given stream and slice begin
index.
Creates a matching outgoing stream for the given stream and slice begin index .
fn out_stream(in_stream: &Stream, messages_begin: StreamIndex) -> Stream {
    Stream::new(
        StreamIndexedQueue::with_begin(in_stream.signals_end()),
        messages_begin,
    )
}
fn out_stream ( in_stream : & Stream , messages_begin : StreamIndex ) -> Stream { Stream :: new ( StreamIndexedQueue :: with_begin ( in_stream . signals_end ( ) ) , messages_begin , ) }
Creates a matching outgoing stream for the given stream and slice begin
index.
Creates a matching outgoing stream for the given stream and slice begin index .
in_stream
&Stream
messages_begin
StreamIndex
in_stream
&Stream
messages_begin
StreamIndex