async fn create_pool(
        &self,
        request: &CreatePool,
    ) -> Result<Pool, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_pool = ctx
            .client
            .create_pool(bus_pool_to_rpc(&request))
            .await
            .context(GrpcCreatePool {})?;

        Ok(rpc_pool_to_bus(&rpc_pool.into_inner(), self.id()))
    }
/// Create a pool on the node via gRPC
Create a pool on the node via gRPC
Create a pool on the node via gRPC
async fn create_pool(
        &self,
        request: &CreatePool,
    ) -> Result<Pool, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_pool = ctx
            .client
            .create_pool(bus_pool_to_rpc(&request))
            .await
            .context(GrpcCreatePool {})?;
        Ok(rpc_pool_to_bus(&rpc_pool.into_inner(), self.id()))
    }
async fn create_pool ( & self , request : & CreatePool , ) -> Result < Pool , SvcError > { let mut ctx = self . grpc_client ( ) . await ? ; let rpc_pool = ctx . client . create_pool ( bus_pool_to_rpc ( & request ) ) . await . context ( GrpcCreatePool { } ) ? ; Ok ( rpc_pool_to_bus ( & rpc_pool . into_inner ( ) , self . id ( ) ) ) }
Create a pool on the node via gRPC
Create a pool on the node via gRPC
&self
request
&CreatePool