diff options
Diffstat (limited to 'ipfs-api/src/client.rs')
-rw-r--r-- | ipfs-api/src/client.rs | 58 |
1 files changed, 29 insertions, 29 deletions
diff --git a/ipfs-api/src/client.rs b/ipfs-api/src/client.rs index ba48ff3..3278eb2 100644 --- a/ipfs-api/src/client.rs +++ b/ipfs-api/src/client.rs @@ -1058,13 +1058,13 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.files_flush(&None); - /// let req = client.files_flush(&Some("/tmp")); + /// let req = client.files_flush(None); + /// let req = client.files_flush(Some("/tmp")); /// # } /// ``` /// #[inline] - pub fn files_flush(&self, path: &Option<&str>) -> AsyncResponse<response::FilesFlushResponse> { + pub fn files_flush(&self, path: Option<&str>) -> AsyncResponse<response::FilesFlushResponse> { self.request_empty(&request::FilesFlush { path }, None) } @@ -1080,13 +1080,13 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.files_ls(&None); - /// let req = client.files_ls(&Some("/tmp")); + /// let req = client.files_ls(None); + /// let req = client.files_ls(Some("/tmp")); /// # } /// ``` /// #[inline] - pub fn files_ls(&self, path: &Option<&str>) -> AsyncResponse<response::FilesLsResponse> { + pub fn files_ls(&self, path: Option<&str>) -> AsyncResponse<response::FilesLsResponse> { self.request(&request::FilesLs { path }, None) } @@ -1281,14 +1281,14 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.filestore_ls(&Some("QmYPP3BovR2m8UqCZxFbdXSit6SKgExxDkFAPLqiGsap4X")); + /// let req = client.filestore_ls(Some("QmYPP3BovR2m8UqCZxFbdXSit6SKgExxDkFAPLqiGsap4X")); /// # } /// ``` /// #[inline] pub fn filestore_ls( &self, - cid: &Option<&str>, + cid: Option<&str>, ) -> AsyncStreamResponse<response::FilestoreLsResponse> { self.request_stream_json(&request::FilestoreLs { cid }, None) } @@ -1305,14 +1305,14 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.filestore_verify(&None); + /// let req = client.filestore_verify(None); /// # } /// ``` /// #[inline] pub fn filestore_verify( &self, - cid: &Option<&str>, + cid: Option<&str>, ) -> AsyncStreamResponse<response::FilestoreVerifyResponse> { self.request_stream_json(&request::FilestoreVerify { cid }, None) } @@ -1352,13 +1352,13 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.id(&None); - /// let req = client.id(&Some("QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM")); + /// let req = client.id(None); + /// let req = client.id(Some("QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM")); /// # } /// ``` /// #[inline] - pub fn id(&self, peer: &Option<&str>) -> AsyncResponse<response::IdResponse> { + pub fn id(&self, peer: Option<&str>) -> AsyncResponse<response::IdResponse> { self.request(&request::Id { peer }, None) } @@ -1374,7 +1374,7 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.key_gen("test", KeyType::Rsa, &Some(64)); + /// let req = client.key_gen("test", KeyType::Rsa, 64); /// # } /// ``` /// @@ -1383,7 +1383,7 @@ impl IpfsClient { &self, name: &str, kind: request::KeyType, - size: &Option<i32>, + size: i32, ) -> AsyncResponse<response::KeyGenResponse> { self.request(&request::KeyGen { name, kind, size }, None) } @@ -1545,13 +1545,13 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.ls(&None); - /// let req = client.ls(&Some("/ipfs/QmVrLsEDn27sScp3k23sgZNefVTjSAL3wpgW1iWPi4MgoY")); + /// let req = client.ls(None); + /// let req = client.ls(Some("/ipfs/QmVrLsEDn27sScp3k23sgZNefVTjSAL3wpgW1iWPi4MgoY")); /// # } /// ``` /// #[inline] - pub fn ls(&self, path: &Option<&str>) -> AsyncResponse<response::LsResponse> { + pub fn ls(&self, path: Option<&str>) -> AsyncResponse<response::LsResponse> { self.request(&request::Ls { path }, None) } @@ -1727,17 +1727,17 @@ impl IpfsClient { /// let client = IpfsClient::default(&core.handle()); /// let req = client.pin_ls(&None, &None); /// let req = client.pin_ls( - /// &Some("/ipfs/QmVrLsEDn27sScp3k23sgZNefVTjSAL3wpgW1iWPi4MgoY"), - /// &None); - /// let req = client.pin_ls(&None, &Some("direct")); + /// Some("/ipfs/QmVrLsEDn27sScp3k23sgZNefVTjSAL3wpgW1iWPi4MgoY"), + /// None); + /// let req = client.pin_ls(None, Some("direct")); /// # } /// ``` /// #[inline] pub fn pin_ls( &self, - key: &Option<&str>, - typ: &Option<&str>, + key: Option<&str>, + typ: Option<&str>, ) -> AsyncResponse<response::PinLsResponse> { self.request(&request::PinLs { key, typ }, None) } @@ -1784,8 +1784,8 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.ping("QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", &None); - /// let req = client.ping("QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", &Some(15)); + /// let req = client.ping("QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", None); + /// let req = client.ping("QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", Some(15)); /// # } /// ``` /// @@ -1793,7 +1793,7 @@ impl IpfsClient { pub fn ping( &self, peer: &str, - count: &Option<i32>, + count: Option<i32>, ) -> AsyncStreamResponse<response::PingResponse> { self.request_stream_json(&request::Ping { peer, count }, None) } @@ -1831,15 +1831,15 @@ impl IpfsClient { /// # fn main() { /// let mut core = Core::new().unwrap(); /// let client = IpfsClient::default(&core.handle()); - /// let req = client.pubsub_peers(&None); - /// let req = client.pubsub_peers(&Some("feed")); + /// let req = client.pubsub_peers(None); + /// let req = client.pubsub_peers(Some("feed")); /// # } /// ``` /// #[inline] pub fn pubsub_peers( &self, - topic: &Option<&str>, + topic: Option<&str>, ) -> AsyncResponse<response::PubsubPeersResponse> { self.request(&request::PubsubPeers { topic }, None) } |