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

Method into_send_future

src/compute/src/render.rs:1676–1679  ·  view source on GitHub ↗

Returns a Send-safe future that completes when the signal fires. Unlike `StartSignal` itself, the returned future does not retain a reference to the token, so it cannot be used for `drop_on_fire` or `has_fired` checks.

(self)

Source from the content-addressed store, hash-verified

1674 /// Unlike `StartSignal` itself, the returned future does not retain a reference to the token,
1675 /// so it cannot be used for `drop_on_fire` or `has_fired` checks.
1676 pub fn into_send_future(self) -> impl Future<Output = ()> + Send {
1677 use futures::FutureExt;
1678 self.fut.map(|_| ())
1679 }
1680
1681 pub fn drop_on_fire(&self, to_drop: Box<dyn Any>) {
1682 if let Some(token) = self.token_ref.upgrade() {

Callers 2

build_compute_dataflowFunction · 0.80
persist_sourceFunction · 0.80

Calls 1

mapMethod · 0.45

Tested by

no test coverage detected