async fn create_nexus(
        &self,
        request: &CreateNexus,
    ) -> Result<Nexus, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_nexus = ctx
            .client
            .create_nexus(bus_nexus_to_rpc(request))
            .await
            .context(GrpcCreateNexus {})?;
        Ok(rpc_nexus_to_bus(
            &rpc_nexus.into_inner(),
            self.node.id.clone(),
        ))
    }
/// Create a nexus on the node via gRPC
Create a nexus on the node via gRPC
Create a nexus on the node via gRPC
async fn create_nexus(
        &self,
        request: &CreateNexus,
    ) -> Result<Nexus, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_nexus = ctx
            .client
            .create_nexus(bus_nexus_to_rpc(request))
            .await
            .context(GrpcCreateNexus {})?;
        Ok(rpc_nexus_to_bus(
            &rpc_nexus.into_inner(),
            self.node.id.clone(),
        ))
    }
async fn create_nexus ( & self , request : & CreateNexus , ) -> Result < Nexus , SvcError > { let mut ctx = self . grpc_client ( ) . await ? ; let rpc_nexus = ctx . client . create_nexus ( bus_nexus_to_rpc ( request ) ) . await . context ( GrpcCreateNexus { } ) ? ; Ok ( rpc_nexus_to_bus ( & rpc_nexus . into_inner ( ) , self . node . id . clone ( ) , ) ) }
Create a nexus on the node via gRPC
Create a nexus on the node via gRPC
&self
request
&CreateNexus