(&self, lane: SessionLane)
| 314 | } |
| 315 | |
| 316 | pub async fn get_lane_handler(&self, lane: SessionLane) -> LaneHandlerConfig { |
| 317 | self.lane_handlers |
| 318 | .read() |
| 319 | .await |
| 320 | .get(&lane) |
| 321 | .cloned() |
| 322 | .unwrap_or_default() |
| 323 | } |
| 324 | |
| 325 | /// Submit a command to a specific lane |
| 326 | pub async fn submit( |