fn mark_started(&mut self) {
        if let Some((start_to_close, mut dat)) = self.start_to_close_dur_and_dat.take() {
            let started_t = Instant::now();
            let cchan = self.cancel_chan.clone();
            self.start_to_close_handle = Some(tokio::spawn(async move {
                sleep(start_to_close).await;
                if let CancelOrTimeout::Timeout { resolution, .. } = &mut dat {
                    resolution.result =
                        LocalActivityExecutionResult::timeout(TimeoutType::StartToClose);
                    resolution.runtime = started_t.elapsed();
                }

                cchan.send(dat).expect("receive half not dropped");
            }));
        }
    }
/// Must be called once the associated local activity has been started / dispatched to lang.
Must be called once the associated local activity has been started / dispatched to lang.
Must be called once the associated local activity has been started / dispatched to lang .
fn mark_started(&mut self) {
        if let Some((start_to_close, mut dat)) = self.start_to_close_dur_and_dat.take() {
            let started_t = Instant::now();
            let cchan = self.cancel_chan.clone();
            self.start_to_close_handle = Some(tokio::spawn(async move {
                sleep(start_to_close).await;
                if let CancelOrTimeout::Timeout { resolution, .. } = &mut dat {
                    resolution.result =
                        LocalActivityExecutionResult::timeout(TimeoutType::StartToClose);
                    resolution.runtime = started_t.elapsed();
                }
                cchan.send(dat).expect("receive half not dropped");
            }));
        }
    }
fn mark_started ( & mut self ) { if let Some ( ( start_to_close , mut dat ) ) = self . start_to_close_dur_and_dat . take ( ) { let started_t = Instant :: now ( ) ; let cchan = self . cancel_chan . clone ( ) ; self . start_to_close_handle = Some ( tokio :: spawn ( async move { sleep ( start_to_close ) . await ; if let CancelOrTimeout :: Timeout { resolution , .. } = & mut dat { resolution . result = LocalActivityExecutionResult :: timeout ( TimeoutType :: StartToClose ) ; resolution . runtime = started_t . elapsed ( ) ; } cchan . send ( dat ) . expect ( " " ) ; } ) ) ; } }
Must be called once the associated local activity has been started / dispatched to lang.
Must be called once the associated local activity has been started / dispatched to lang .
&mut self
&mut self