Searched refs:event_messages (Results 1 – 1 of 1) sorted by relevance
587 let mut event_messages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone())); in on_play() localVariable588 event_messages.write_stream_begin(*stream_id).await?; in on_play()633 event_messages.write_stream_is_record(*stream_id).await?; in on_play()716 let mut event_messages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone())); in on_publish() localVariable717 event_messages.write_stream_begin(*stream_id).await?; in on_publish()