(
mut inner: Box<dyn OpaqueDebugger + Send + 'static>,
resumption: wit::ResumptionValue,
)
| 120 | } |
| 121 | |
| 122 | fn new_continue( |
| 123 | mut inner: Box<dyn OpaqueDebugger + Send + 'static>, |
| 124 | resumption: wit::ResumptionValue, |
| 125 | ) -> Self { |
| 126 | EventFuture { |
| 127 | state: EventFutureState::Running(Box::pin(async move { |
| 128 | if let Err(e) = inner.handle_resumption(&resumption).await { |
| 129 | return (inner, Err(e)); |
| 130 | } |
| 131 | let result = inner.continue_().await; |
| 132 | (inner, result) |
| 133 | })), |
| 134 | } |
| 135 | } |
| 136 | } |
| 137 | |
| 138 | #[async_trait::async_trait] |
nothing calls this directly
no test coverage detected