Lines Matching refs:RpcStatus

19 use super::{RpcStatus, ShareCall, ShareCallHolder, WriteFlags};
255         let status = RpcStatus::new(RpcStatusCode::INTERNAL, Some("No payload".to_owned()));  in handle()
353                 self.complete(RpcStatus::ok(), Some(t))
356             pub fn fail(self, status: RpcStatus) -> $rt {
360             fn complete(mut self, status: RpcStatus, t: Option<T>) -> $rt {
431             status: RpcStatus,
443                     status: RpcStatus::ok(),
463             pub fn set_status(&mut self, status: RpcStatus) {
468             pub fn fail(mut self, status: RpcStatus) -> $ft {
706             let status = RpcStatus::new(  in execute_unary()
752             let status = RpcStatus::new(  in execute_server_streaming()
789     call.abort(&RpcStatus::new(RpcStatusCode::UNIMPLEMENTED, None))  in execute_unimplemented()