(
&self,
socket_path: impl AsRef<Path>,
)
| 118 | |
| 119 | #[cfg(unix)] |
| 120 | pub fn serve_uds( |
| 121 | &self, |
| 122 | socket_path: impl AsRef<Path>, |
| 123 | ) -> io::Result<FakeComputeDriverServerHandle> { |
| 124 | let socket_path = socket_path.as_ref().to_path_buf(); |
| 125 | let listener = UnixListener::bind(&socket_path)?; |
| 126 | let driver = self.clone(); |
| 127 | let task = tokio::spawn(async move { |
| 128 | tonic::transport::Server::builder() |
| 129 | .add_service(ComputeDriverServer::new(driver)) |
| 130 | .serve_with_incoming(UnixIncoming { listener }) |
| 131 | .await |
| 132 | }); |
| 133 | Ok(FakeComputeDriverServerHandle { socket_path, task }) |
| 134 | } |
| 135 | |
| 136 | fn with_state<R>(&self, f: impl FnOnce(&mut FakeComputeDriverState) -> R) -> R { |
| 137 | let mut state = self |
no test coverage detected