pub fn subscribe(&mut self) -> Result<(), BoxError> {
        let mut subscriptions = vec![];

        for query in &self.event_queries {
            let subscription = self
                .rt
                .block_on(self.websocket_client.subscribe(query.clone()))?;

            subscriptions.push(subscription);
        }

        self.subscriptions = Box::new(select_all(subscriptions));

        Ok(())
    }
/// Clear the current subscriptions, and subscribe again to all queries.
Clear the current subscriptions, and subscribe again to all queries.
Clear the current subscriptions and subscribe again to all queries .
pub fn subscribe(&mut self) -> Result<(), BoxError> {
        let mut subscriptions = vec![];
        for query in &self.event_queries {
            let subscription = self
                .rt
                .block_on(self.websocket_client.subscribe(query.clone()))?;
            subscriptions.push(subscription);
        }
        self.subscriptions = Box::new(select_all(subscriptions));
        Ok(())
    }
pub fn subscribe ( & mut self ) -> Result < ( ) , BoxError > { let mut subscriptions = vec ! [ ] ; for query in & self . event_queries { let subscription = self . rt . block_on ( self . websocket_client . subscribe ( query . clone ( ) ) ) ? ; subscriptions . push ( subscription ) ; } self . subscriptions = Box :: new ( select_all ( subscriptions ) ) ; Ok ( ( ) ) }
Clear the current subscriptions, and subscribe again to all queries.
Clear the current subscriptions and subscribe again to all queries .
&mut self
&mut self