MCPcopy Create free account
hub / github.com/bytecodealliance/wasmtime / blocking_check_send

Method blocking_check_send

crates/test-programs/src/sockets.rs:218–227  ·  view source on GitHub ↗
(&self, timeout: &Pollable)

Source from the content-addressed store, hash-verified

216
217impl OutgoingDatagramStream {
218 fn blocking_check_send(&self, timeout: &Pollable) -> Result<u64, ErrorCode> {
219 let sub = self.subscribe();
220
221 loop {
222 match self.check_send() {
223 Ok(0) => sub.block_until(timeout)?,
224 result => return result,
225 }
226 }
227 }
228
229 pub fn blocking_send(&self, mut datagrams: &[OutgoingDatagram]) -> Result<(), ErrorCode> {
230 let timeout = monotonic_clock::subscribe_duration(TIMEOUT_NS);

Callers 1

blocking_sendMethod · 0.80

Calls 3

check_sendMethod · 0.80
block_untilMethod · 0.80
subscribeMethod · 0.45

Tested by

no test coverage detected