Searched refs:OutgoingMessage (Results 1 – 8 of 8) sorted by relevance
116 pub fn send(&mut self, message: &OutgoingMessage) -> Result<(), MessageError> { in send()145 pub fn send(&self, message: &OutgoingMessage) -> Result<(), MessageError> { in send()155 IncomingMessage::FormatValue { value } => OutgoingMessage::FormattedValue { in serve_value_formatter()159 OutgoingMessage::FormattedValue { in serve_value_formatter()168 OutgoingMessage::ScaledValues { in serve_value_formatter()179 OutgoingMessage::ScaledValues { in serve_value_formatter()186 OutgoingMessage::ScaledValues { in serve_value_formatter()230 pub enum OutgoingMessage<'a> { enum
4 use crate::connection::OutgoingMessage;330 conn.send(&OutgoingMessage::BeginningBenchmarkGroup { group: group_id }) in run()371 conn.send(&OutgoingMessage::FinishedBenchmarkGroup { group: group_id }) in run()492 conn.send(&OutgoingMessage::BeginningBenchmarkGroup { group: group_id }) in run()542 conn.send(&OutgoingMessage::FinishedBenchmarkGroup { group: group_id }) in run()576 conn.send(&OutgoingMessage::BeginningBenchmark { id: id.into() }) in execute_benchmark()579 conn.send(&OutgoingMessage::SkippingBenchmark { id: id.into() }) in execute_benchmark()
3 use crate::connection::OutgoingMessage;311 conn.send(&OutgoingMessage::BeginningBenchmark { id: (&id).into() }) in run_bench()314 conn.send(&OutgoingMessage::SkippingBenchmark { id: (&id).into() }) in run_bench()373 conn.send(&OutgoingMessage::FinishedBenchmarkGroup { in drop()
2 use crate::connection::OutgoingMessage;99 conn.send(&OutgoingMessage::Warmup { in sample()144 conn.send(&OutgoingMessage::MeasurementStart { in sample()
95 use crate::connection::OutgoingMessage;1104 conn.send(&OutgoingMessage::BeginningBenchmarkGroup { group: &group_name }) in benchmark_group()
113 class OutgoingMessage {115 OutgoingMessage(const rtc::CopyOnWriteBuffer& buffer, in OutgoingMessage() function164 SendDataResult SendMessageInternal(OutgoingMessage* message);214 absl::optional<OutgoingMessage> partial_outgoing_message_;
601 OutgoingMessage message(payload, params); in SendData()624 SendDataResult SctpTransport::SendMessageInternal(OutgoingMessage* message) { in SendMessageInternal()
10 use crate::connection::OutgoingMessage;96 conn.send(&OutgoingMessage::MeasurementComplete { in common()