Remove try_get_record() and other try_...() non-async methods

Author: dmitry-markin

src/protocol/libp2p/kademlia/handle.rs

@@ -338,70 +338,6 @@ impl KademliaHandle {
     pub async fn store_record(&mut self, record: Record) {
         let _ = self.cmd_tx.send(KademliaCommand::StoreRecord { record }).await;
     }
-
-    /// Try to add known peer and if the channel is clogged, return an error.
-    pub fn try_add_known_peer(&self, peer: PeerId, addresses: Vec<Multiaddr>) -> Result<(), ()> {
-        self.cmd_tx
-            .try_send(KademliaCommand::AddKnownPeer { peer, addresses })
-            .map_err(|_| ())
-    }
-
-    /// Try to initiate `FIND_NODE` query and if the channel is clogged, return an error.
-    pub fn try_find_node(&mut self, peer: PeerId) -> Result<QueryId, ()> {
-        let query_id = self.next_query_id();
-        self.cmd_tx
-            .try_send(KademliaCommand::FindNode { peer, query_id })
-            .map(|_| query_id)
-            .map_err(|_| ())
-    }
-
-    /// Try to initiate `PUT_VALUE` query and if the channel is clogged, return an error.
-    pub fn try_put_record(&mut self, record: Record) -> Result<QueryId, ()> {
-        let query_id = self.next_query_id();
-        self.cmd_tx
-            .try_send(KademliaCommand::PutRecord { record, query_id })
-            .map(|_| query_id)
-            .map_err(|_| ())
-    }
-
-    /// Try to initiate `PUT_VALUE` query to the given peers and if the channel is clogged,
-    /// return an error.
-    pub fn try_put_record_to_peers(
-        &mut self,
-        record: Record,
-        peers: Vec<PeerId>,
-        update_local_store: bool,
-    ) -> Result<QueryId, ()> {
-        let query_id = self.next_query_id();
-        self.cmd_tx
-            .try_send(KademliaCommand::PutRecordToPeers {
-                record,
-                query_id,
-                peers,
-                update_local_store,
-            })
-            .map(|_| query_id)
-            .map_err(|_| ())
-    }
-
-    /// Try to initiate `GET_VALUE` query and if the channel is clogged, return an error.
-    pub fn try_get_record(&mut self, key: RecordKey, quorum: Quorum) -> Result<QueryId, ()> {
-        let query_id = self.next_query_id();
-        self.cmd_tx
-            .try_send(KademliaCommand::GetRecord {
-                key,
-                quorum,
-                query_id,
-            })
-            .map(|_| query_id)
-            .map_err(|_| ())
-    }
-
-    /// Try to store the record in the local store, and if the channel is clogged, return an error.
-    /// Used in combination with [`IncomingRecordValidationMode::Manual`].
-    pub fn try_store_record(&mut self, record: Record) -> Result<(), ()> {
-        self.cmd_tx.try_send(KademliaCommand::StoreRecord { record }).map_err(|_| ())
-    }
 }
 
 impl Stream for KademliaHandle {