MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / flush

Method flush

src/pgwire/src/protocol.rs:1847–1850  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

1845 }
1846
1847 async fn flush(&mut self) -> Result<State, io::Error> {
1848 self.conn.flush().await?;
1849 Ok(State::Ready)
1850 }
1851
1852 /// Sends a backend message to the client, after applying a severity filter.
1853 ///

Callers 9

runFunction · 0.45
advance_readyMethod · 0.45
sendMethod · 0.45
readyMethod · 0.45
send_execute_responseMethod · 0.45
send_rowsMethod · 0.45
copy_rowsMethod · 0.45
copy_from_innerMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected