Searched refs:eventmessages (Results 1 – 1 of 1) sorted by relevance
458 let mut eventmessages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone())); in send_set_buffer_length() localVariable459 eventmessages.write_set_buffer_length(stream_id, ms).await?; in send_set_buffer_length()