diff options
Diffstat (limited to 'lib/src/client.rs')
| -rw-r--r-- | lib/src/client.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/src/client.rs b/lib/src/client.rs index d985769..2128f76 100644 --- a/lib/src/client.rs +++ b/lib/src/client.rs @@ -122,6 +122,10 @@ impl Client { self.get::<S>(cid).await.map(|v| v.0) } + + pub async fn pubsub_subscribe(&self, topic: String) -> Result<ipfs::SubscriptionStream> { + self.ipfs.pubsub_subscribe(topic).await.map_err(anyhow::Error::from) + } } fn now() -> DateTime { |