Method subscribe

fendermint/eth/api/src/client.rs:84–93

(&self, query: Query)

#[async_trait]
impl SubscriptionClient for HybridClient {
    async fn subscribe(&self, query: Query) -> Result<Subscription, Error> {
        let (tx, rx) = tokio::sync::oneshot::channel();

        self.cmd_tx
            .send(DriverCommand::Subscribe(query, tx))
            .map_err(|_| Error::channel_send())?;

        rx.await
            .map_err(|e| Error::client_internal(e.to_string()))?
    }

    async fn unsubscribe(&self, query: Query) -> Result<(), Error> {
        let (tx, rx) = tokio::sync::oneshot::channel();