| /wasmtime-44.0.1/crates/wasi-io/src/ |
| H A D | streams.rs | 1 use crate::poll::Pollable;
18 pub trait InputStream: Pollable {
126 pub trait OutputStream: Pollable {
272 impl Pollable for Box<dyn OutputStream> {
279 impl Pollable for Box<dyn InputStream> {
|
| H A D | poll.rs | 67 pub trait Pollable: Send + 'static { interface
95 T: Pollable, in subscribe()
99 T: Pollable, in subscribe()
|
| /wasmtime-44.0.1/crates/wasi/src/cli/ |
| H A D | file.rs | 2 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
45 impl Pollable for OutputFile {
121 impl Pollable for InputFile {
|
| H A D | worker_thread_stdin.rs | 37 poll::Pollable,
172 impl Pollable for WasiStdin {
|
| H A D | locked_async.rs | 105 impl p2::Pollable for AsyncStdinStream {
211 impl p2::Pollable for AsyncStdoutStream {
|
| H A D | stdout.rs | 120 impl p2::Pollable for StdioOutputStream {
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | udp.rs | 4 use crate::p2::{Pollable, SocketError, SocketResult};
171 impl Pollable for UdpSocket {
257 impl Pollable for IncomingDatagramStream {
387 impl Pollable for OutgoingDatagramStream {
423 IncomingDatagram, IpAddressFamily, IpSocketAddress, OutgoingDatagram, Pollable,
523 ) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
549 ) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
591 ) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
|
| H A D | io.rs | 3 bindings::sync::io::poll::Pollable,
64 ) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
125 fn subscribe(&mut self, stream: Resource<InputStream>) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
|
| H A D | clocks.rs | 10 use wasmtime_wasi_io::poll::{Pollable, subscribe};
124 impl Pollable for Deadline {
|
| H A D | tcp.rs | 5 use crate::p2::{Pollable, SocketResult};
276 impl Pollable for TcpSocket {
292 OutputStream, Pollable, ShutdownType, TcpSocket,
484 ) -> wasmtime::Result<Resource<Pollable>> { in subscribe() argument
|
| /wasmtime-44.0.1/crates/wasi/src/p2/ |
| H A D | ip_name_lookup.rs | 12 use wasmtime_wasi_io::poll::{DynPollable, Pollable, subscribe};
80 impl Pollable for ResolveAddressStream {
|
| H A D | pipe.rs | 18 poll::Pollable,
56 impl Pollable for MemoryInputPipe {
126 impl Pollable for MemoryOutputPipe {
266 impl Pollable for AsyncReadStream {
293 impl Pollable for SinkOutputStream {
309 impl Pollable for ClosedInputStream {
332 impl Pollable for ClosedOutputStream {
|
| H A D | tcp.rs | 2 DynInputStream, DynOutputStream, InputStream, OutputStream, Pollable, SocketError,
116 impl Pollable for TcpReadStream {
334 impl Pollable for TcpWriteStream {
|
| H A D | write_stream.rs | 1 use crate::p2::{OutputStream, Pollable, StreamError};
209 impl Pollable for AsyncWriteStream {
|
| H A D | filesystem.rs | 4 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
184 impl Pollable for FileInputStream {
382 impl Pollable for FileOutputStream {
|
| H A D | mod.rs | 255 pub use wasmtime_wasi_io::poll::{DynFuture, DynPollable, MakeFuture, Pollable, subscribe};
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | sockets.rs | 2 use crate::wasi::io::poll::{self, Pollable};
24 impl Pollable { implementation
25 pub fn block_until(&self, timeout: &Pollable) -> Result<(), ErrorCode> { in block_until()
218 fn blocking_check_send(&self, timeout: &Pollable) -> Result<u64, ErrorCode> { in blocking_check_send()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | host.rs | 4 use wasmtime_wasi::p2::Pollable;
83 impl Pollable for HostFutureClientStreams {
|
| H A D | io.rs | 14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
61 impl<T> Pollable for WasiFuture<T>
258 impl<IO> Pollable for AsyncWriteStream<IO>
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | body.rs | 15 use wasmtime_wasi::p2::{InputStream, OutputStream, Pollable, StreamError};
273 impl Pollable for HostIncomingBodyStream {
329 impl Pollable for HostFutureTrailers {
668 impl Pollable for BodyWriteStream {
|
| H A D | types.rs | 16 use wasmtime_wasi::p2::Pollable;
295 impl Pollable for HostFutureIncomingResponse {
|
| /wasmtime-44.0.1/examples/min-platform/embedding/src/ |
| H A D | wasi.rs | 39 poll::{DynPollable, Pollable, subscribe},
275 impl Pollable for Deadline {
285 impl Pollable for NeverReadable {
335 impl Pollable for WriteLog {
|
| /wasmtime-44.0.1/crates/wasi/tests/ |
| H A D | process_stdin.rs | 4 use wasmtime_wasi::p2::Pollable;
|
| /wasmtime-44.0.1/crates/wasi-preview1-component-adapter/src/ |
| H A D | lib.rs | 30 use poll::Pollable;
2060 pointer: *mut Pollable,
2066 unsafe fn push(&mut self, pollable: Pollable) { in push() argument
2107 assert!(align_of::<Event>() >= align_of::<Pollable>()); in poll_oneoff()
2108 assert!(align_of::<Pollable>() >= align_of::<u32>()); in poll_oneoff()
2114 .checked_mul(size_of::<Pollable>()) in poll_oneoff()
2125 let pollables = out as *mut c_void as *mut Pollable; in poll_oneoff()
2215 fn poll_import(pollables: *const Pollable, len: usize, rval: *mut ReadyList); in poll_oneoff() argument
|
| /wasmtime-44.0.1/crates/c-api/src/ |
| H A D | wasi.rs | 194 impl wasmtime_wasi::p2::Pollable for CustomOutputStream {
|