Lines Matching refs:ReceiverMessage
21 ReceiverMessage::Type reply_type, in ReplyIfTimedOut()
30 it->second(ReceiverMessage{reply_type, sequence_number}); in ReplyIfTimedOut()
81 void SenderSessionMessager::SetHandler(ReceiverMessage::Type type, in SetHandler()
84 OSP_DCHECK(type == ReceiverMessage::Type::kRpc); in SetHandler()
100 ReceiverMessage::Type reply_type, in SendRequest()
104 OSP_DCHECK(reply_type != ReceiverMessage::Type::kRpc); in SendRequest()
160 ErrorOr<ReceiverMessage> receiver_message = in OnMessage()
161 ReceiverMessage::Parse(message_body.value()); in OnMessage()
168 if (receiver_message.value().type == ReceiverMessage::Type::kRpc) { in OnMessage()
202 Error ReceiverSessionMessager::SendMessage(ReceiverMessage message) { in SendMessage()
208 const auto namespace_ = (message.type == ReceiverMessage::Type::kRpc) in SendMessage()