Method create

flow-rs/src/node/port.rs:70–88

(
        &mut self,
        key: u64,
        resource: ResourceCollection,
        args: Table,
    )

    }

    pub async fn create(
        &mut self,
        key: u64,
        resource: ResourceCollection,
        args: Table,
    ) -> Result<JoinHandle<Result<()>>> {
        self.create_spec(
            key,
            self.brokers
                .keys()
                .next()
                .expect("not init")
                .clone()
                .as_str(),
            resource,
            args,
        )
        .await
    }

    pub async fn create_spec(
        &mut self,