(&self, req: InvokeRequest)
| 123 | } |
| 124 | |
| 125 | pub async fn push(&self, req: InvokeRequest) -> Result<(), ServerError> { |
| 126 | self.tx |
| 127 | .send(req) |
| 128 | .await |
| 129 | .map_err(|e| ServerError::SendInvokeMessage(Box::new(e)))?; |
| 130 | self.depth.fetch_add(1, Ordering::Relaxed); |
| 131 | Ok(()) |
| 132 | } |
| 133 | |
| 134 | pub fn depth(&self) -> usize { |
| 135 | self.depth.load(Ordering::Relaxed) |