Searched refs:received (Results 1 – 7 of 7) sorted by relevance
44 while let Some(received) = resp_stream.next().await { in bidirectional_streaming_echo()45 let received = received.unwrap(); in bidirectional_streaming_echo() localVariable46 println!("\treceived message: `{}`", received.message); in bidirectional_streaming_echo()60 while let Some(received) = resp_stream.next().await { in bidirectional_streaming_echo_throttle()61 let received = received.unwrap(); in bidirectional_streaming_echo_throttle() localVariable62 println!("\treceived message: `{}`", received.message); in bidirectional_streaming_echo_throttle()
93 // A RouteSummary is received in response to a RecordRoute rpc.95 // It contains the number of individual points received, the number of99 // The number of points received.
52 // If the requested service is unknown when the call is received, the
111 // Aggregated size of payloads received from the client.
112 vector of standard error messages that will be generated or that was received,
235 // delivered to subscribers in the order in which they are received by the700 // are received by the Pub/Sub system. Otherwise, they may be delivered in875 // This ID can be used to acknowledge the received message.1079 // List of acknowledgement IDs for acknowledging previously received messages1080 // (received on this stream or a different stream). If an ack ID has expired,1093 // will expire 10 seconds after this request is received. If the value is 0,
67 * **tonic:** flush accumulated ready messages when status received ([#1756](https://github.com/hype…