pub fn with_messages(mut self, begin: StreamIndex, msgs: Vec<Request>) -> Self {
        self.messages = StreamIndexedQueue::with_begin(begin);
        for msg in msgs {
            self.messages.push(msg.into());
        }
        self
    }
/// Sets the stream messages to the provided ones, starting at the given
/// index.
Sets the stream messages to the provided ones, starting at the given
index.
Sets the stream messages to the provided ones starting at the given index .
pub fn with_messages(mut self, begin: StreamIndex, msgs: Vec<Request>) -> Self {
        self.messages = StreamIndexedQueue::with_begin(begin);
        for msg in msgs {
            self.messages.push(msg.into());
        }
        self
    }
pub fn with_messages ( mut self , begin : StreamIndex , msgs : Vec < Request > ) -> Self { self . messages = StreamIndexedQueue :: with_begin ( begin ) ; for msg in msgs { self . messages . push ( msg . into ( ) ) ; } self }
Sets the stream messages to the provided ones, starting at the given
index.
Sets the stream messages to the provided ones starting at the given index .
mut self
begin
StreamIndex
msgs
Vec<Request>
mut self
begin
StreamIndex
msgs
Vec<Request>