async fn upper<K, V>(
        &mut self,
        collection: StashCollection<K, V>,
    ) -> Result<Antichain<Timestamp>, StashError>
    where
        K: Data,
        V: Data,
    {
        let tx = self.conn.transaction()?;
        let upper = Self::upper_tx(&tx, collection.id)?;
        tx.commit()?;
        Ok(upper)
    }
/// Reports the current upper frontier.
Reports the current upper frontier.
Reports the current upper frontier .
async fn upper<K, V>(
        &mut self,
        collection: StashCollection<K, V>,
    ) -> Result<Antichain<Timestamp>, StashError>
    where
        K: Data,
        V: Data,
    {
        let tx = self.conn.transaction()?;
        let upper = Self::upper_tx(&tx, collection.id)?;
        tx.commit()?;
        Ok(upper)
    }
async fn upper < K , V > ( & mut self , collection : StashCollection < K , V > , ) -> Result < Antichain < Timestamp > , StashError > where K : Data , V : Data , { let tx = self . conn . transaction ( ) ? ; let upper = Self :: upper_tx ( & tx , collection . id ) ? ; tx . commit ( ) ? ; Ok ( upper ) }
Reports the current upper frontier.
Reports the current upper frontier .
&mut self
collection
StashCollection<K, V>
&mut self
collection
StashCollection<K, V>