-
Notifications
You must be signed in to change notification settings - Fork 44
Closed
Description
There are functions that do not contain async code. Currently, I need to use futures::executor::block_on
to execute these two functions.
Lines 113 to 115 in bd61405
pub async fn controller_client(&self) -> Result<ControllerClient> { Ok(ControllerClient::new(Arc::clone(&self.brokers))) } rskafka/src/client/controller.rs
Lines 30 to 37 in bd61405
impl ControllerClient { pub(super) fn new(brokers: Arc<BrokerConnector>) -> Self { Self { brokers, backoff_config: Default::default(), current_broker: Mutex::new(None), } } Lines 118 to 128 in bd61405
pub async fn partition_client( &self, topic: impl Into<String> + Send, partition: i32, ) -> Result<PartitionClient> { Ok(PartitionClient::new( topic.into(), partition, Arc::clone(&self.brokers), )) }
Could async be removed for these two or is there a reason it is used?
Metadata
Metadata
Assignees
Labels
No labels