Home
last modified time | relevance | path

Searched refs:StreamResult (Results 1 – 25 of 38) sorted by relevance

12

/wasmtime-44.0.1/crates/wasi-tls/src/p3/util/
H A Dtokio_streams.rs48 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
50 return Poll::Ready(Ok(StreamResult::Dropped)); in poll_produce()
71 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
76 Poll::Ready(Ok(StreamResult::Completed)) in poll_produce()
80 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
123 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
138 StreamResult::Cancelled in poll_consume()
140 StreamResult::Completed in poll_consume()
147 Poll::Ready(Ok(StreamResult::Dropped)) in poll_consume()
151 Poll::Ready(Ok(StreamResult::Completed)) in poll_consume()
[all …]
H A Dclosed.rs8 use wasmtime::component::{Destination, Source, StreamConsumer, StreamProducer, StreamResult};
49 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
50 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
62 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
63 Poll::Ready(Ok(StreamResult::Dropped)) in poll_consume()
/wasmtime-44.0.1/crates/wasi/src/p2/host/
H A Dio.rs2 StreamError, StreamResult,
33 fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64> { in check_write()
37 fn write(&mut self, stream: Resource<OutputStream>, bytes: Vec<u8>) -> StreamResult<()> { in write() argument
45 ) -> StreamResult<()> { in blocking_write_and_flush() argument
55 ) -> StreamResult<()> { in blocking_write_zeroes_and_flush() argument
72 fn flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()> { in flush() argument
79 fn blocking_flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()> { in blocking_flush() argument
90 ) -> StreamResult<u64> { in splice()
99 ) -> StreamResult<u64> { in blocking_splice()
109 fn read(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<Vec<u8>> { in read()
[all …]
/wasmtime-44.0.1/crates/wasi-io/src/
H A Dstreams.rs31 fn read(&mut self, size: usize) -> StreamResult<Bytes>; in read()
35 async fn blocking_read(&mut self, size: usize) -> StreamResult<Bytes> { in blocking_read()
60 fn skip(&mut self, nelem: usize) -> StreamResult<usize> { in skip()
67 async fn blocking_skip(&mut self, nelem: usize) -> StreamResult<usize> { in blocking_skip()
83 pub type StreamResult<T> = Result<T, StreamError>; typedef
143 fn write(&mut self, bytes: Bytes) -> StreamResult<()>; in write() argument
164 fn flush(&mut self) -> StreamResult<()>; in flush() argument
178 fn check_write(&mut self) -> StreamResult<usize>; in check_write()
204 async fn blocking_write_and_flush(&mut self, mut bytes: Bytes) -> StreamResult<()> { in blocking_write_and_flush() argument
235 fn write_zeroes(&mut self, nelem: usize) -> StreamResult<()> { in write_zeroes() argument
[all …]
H A Dimpls.rs3 use crate::streams::{DynInputStream, DynOutputStream, StreamError, StreamResult};
126 fn check_write(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<u64> { in check_write()
144 ) -> StreamResult<()> { in blocking_write_and_flush() argument
160 ) -> StreamResult<()> { in blocking_write_zeroes_and_flush() argument
178 fn flush(&mut self, stream: Resource<DynOutputStream>) -> StreamResult<()> { in flush() argument
195 ) -> StreamResult<u64> { in splice()
224 ) -> StreamResult<u64> { in blocking_splice()
255 fn read(&mut self, stream: Resource<DynInputStream>, len: u64) -> StreamResult<Vec<u8>> { in read()
266 ) -> StreamResult<Vec<u8>> { in blocking_read()
273 fn skip(&mut self, stream: Resource<DynInputStream>, len: u64) -> StreamResult<u64> { in skip()
[all …]
/wasmtime-44.0.1/crates/misc/component-async-tests/src/
H A Dutil.rs12 StreamProducer, StreamResult,
42 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
50 Poll::Ready(Ok(StreamResult::Cancelled)) in poll_produce()
57 Poll::Ready(Ok(StreamResult::Completed)) in poll_produce()
59 Poll::Ready(None) => Poll::Ready(Ok(StreamResult::Dropped)), in poll_produce()
83 ) -> Poll<Result<StreamResult>> { in poll_consume() argument
90 Poll::Ready(Ok(StreamResult::Cancelled)) in poll_consume()
107 Poll::Ready(Ok(StreamResult::Completed)) in poll_consume()
/wasmtime-44.0.1/crates/wasi/src/p3/cli/
H A Dhost.rs18 StreamReader, StreamResult,
47 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
56 return Poll::Ready(Ok(StreamResult::Completed)); in poll_produce()
63 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
68 Poll::Ready(Ok(StreamResult::Completed)) in poll_produce()
76 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
78 Poll::Pending if finish => Poll::Ready(Ok(StreamResult::Cancelled)), in poll_produce()
98 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
110 return Poll::Ready(Ok(StreamResult::Completed)); in poll_consume()
115 Poll::Ready(Ok(StreamResult::Completed)) in poll_consume()
[all …]
/wasmtime-44.0.1/crates/wasi/src/p3/
H A Dmod.rs24 use wasmtime::component::{Destination, Linker, StreamProducer, StreamResult, VecBuffer};
61 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
69 return Poll::Ready(Ok(StreamResult::Completed)); in poll_produce()
82 break StreamResult::Dropped; in poll_produce()
87 break StreamResult::Dropped; in poll_produce()
91 break StreamResult::Completed; in poll_produce()
/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dasync_short_reads.rs6 wit_bindgen::{StreamReader, StreamResult, rt::async_support},
50 StreamResult::Complete(_) => { in short_reads()
53 StreamResult::Dropped => break, in short_reads()
54 StreamResult::Cancelled => unreachable!(), in short_reads()
H A Dp3_sockets_tcp_sample_application.rs7 use wit_bindgen::StreamResult;
36 assert_eq!(result, StreamResult::Complete(0)); in test_tcp_sample_application()
47 assert_eq!(result, StreamResult::Complete(first_message.len())); in test_tcp_sample_application()
52 assert_eq!(result, StreamResult::Dropped); in test_tcp_sample_application()
80 assert_eq!(result, StreamResult::Complete(second_message.len())); in test_tcp_sample_application()
85 assert_eq!(result, StreamResult::Dropped); in test_tcp_sample_application()
H A Dp3_http_echo.rs7 wit_bindgen::StreamResult,
41 StreamResult::Complete(_) => { in handle()
45 StreamResult::Dropped => break, in handle()
46 StreamResult::Cancelled => unreachable!(), in handle()
H A Dp3_sockets_tcp_streams.rs9 use wit_bindgen::{FutureReader, StreamReader, StreamResult, StreamWriter};
24 assert_eq!(status, StreamResult::Complete(4)); in test_tcp_ping_pong()
33 assert_eq!(status, StreamResult::Complete(4)); in test_tcp_ping_pong()
49 assert_eq!(stream_result, StreamResult::Dropped); in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
99 if stream_result == StreamResult::Dropped { in test_tcp_send_drops_stream_when_remote_shutdown()
132 assert_eq!(stream_result, StreamResult::Dropped); in test_tcp_receive_once()
151 assert_eq!(stream_result, StreamResult::Dropped); in test_tcp_send_once()
247 StreamResult::Complete(n) => { in test_tcp_read_cancellation()
256 StreamResult::Dropped => break, in test_tcp_read_cancellation()
257 StreamResult::Cancelled => { in test_tcp_read_cancellation()
H A Dp3_cli.rs5 use wit_bindgen::StreamResult;
31 assert_eq!(res, StreamResult::Complete(13)); in run()
44 assert_eq!(res, StreamResult::Complete(13)); in run()
H A Dasync_transmit_callee.rs17 wit_bindgen::{FutureReader, StreamReader, StreamResult},
49 StreamResult::Complete(0) in exchange()
61 StreamResult::Complete(0) in exchange()
H A Dp3_http_middleware.rs14 wit_bindgen::StreamResult,
82 let mut status = StreamResult::Complete(0); in handle()
85 while let StreamResult::Complete(_) = status { in handle()
146 let mut status = StreamResult::Complete(0); in handle()
149 while let StreamResult::Complete(_) = status { in handle()
H A Dp3_cli_read_stdin.rs12 assert_eq!(sresult, wit_bindgen::StreamResult::Complete(6)); in run()
16 assert_eq!(sresult, wit_bindgen::StreamResult::Dropped); in run()
H A Dasync_closed_streams.rs15 wit_bindgen::{FutureReader, StreamReader, StreamResult},
26 if !matches!(result, StreamResult::Complete(_)) { in read_stream()
H A Dfuzz_async.rs153 use wit_bindgen::{FutureReader, FutureWriter, StreamReader, StreamResult, StreamWriter};
593 assert_eq!(status, StreamResult::Dropped); in run()
613 assert_eq!(status, StreamResult::Dropped); in run()
636 StreamResult::Complete(n) => { in run()
640 StreamResult::Dropped => { in run()
644 StreamResult::Cancelled => {} in run()
663 type Output = (StreamResult, Vec<u32>); in run()
694 StreamResult::Complete(_) => { in run()
697 StreamResult::Dropped => { in run()
701 StreamResult::Cancelled => {} in run()
[all …]
/wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/
H A Dtcp.rs21 StreamProducer, StreamReader, StreamResult,
66 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
75 return Poll::Ready(Ok(StreamResult::Completed)); in poll_produce()
89 Poll::Ready(Ok(StreamResult::Completed)) in poll_produce()
126 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
146 return Poll::Ready(Ok(StreamResult::Completed)); in poll_produce()
153 return Poll::Ready(Ok(StreamResult::Cancelled)); in poll_produce()
163 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
199 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
217 return Poll::Ready(Ok(StreamResult::Completed)); in poll_consume()
[all …]
/wasmtime-44.0.1/crates/wasi/src/cli/
H A Dfile.rs2 use crate::p2::{InputStream, OutputStream, Pollable, StreamError, StreamResult};
50 fn write(&mut self, bytes: Bytes) -> StreamResult<()> { in write() argument
56 fn flush(&mut self) -> StreamResult<()> { in flush() argument
63 fn check_write(&mut self) -> StreamResult<usize> { in check_write()
126 fn read(&mut self, size: usize) -> StreamResult<Bytes> { in read()
136 StreamResult::Ok(buf.into()) in read()
/wasmtime-44.0.1/crates/wasi-http/src/p3/
H A Dbody.rs18 StreamProducer, StreamReader, StreamResult,
179 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
188 return Poll::Ready(Ok(StreamResult::Dropped)); in poll_consume()
192 return Poll::Ready(Ok(StreamResult::Dropped)); in poll_consume()
196 return Poll::Ready(Ok(StreamResult::Dropped)); in poll_consume()
206 Poll::Ready(Ok(StreamResult::Completed)) in poll_consume()
210 Poll::Ready(Ok(StreamResult::Dropped)) in poll_consume()
216 Poll::Ready(Ok(StreamResult::Dropped)) in poll_consume()
237 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_consume() argument
477 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
[all …]
/wasmtime-44.0.1/crates/misc/component-async-tests/tests/scenario/
H A Dstreams.rs23 StreamProducer, StreamReader, StreamResult, VecBuffer,
41 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
49 Poll::Ready(Ok(StreamResult::Cancelled)) in poll_produce()
58 Poll::Ready(Ok(StreamResult::Completed)) in poll_produce()
78 ) -> Poll<Result<StreamResult>> { in poll_consume() argument
85 Poll::Ready(Ok(StreamResult::Cancelled)) in poll_consume()
103 Poll::Ready(Ok(StreamResult::Completed)) in poll_consume()
327 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
333 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
364 ) -> Poll<Result<StreamResult>> { in poll_consume() argument
[all …]
/wasmtime-44.0.1/crates/wasi/src/p3/filesystem/
H A Dhost.rs22 StreamProducer, StreamReader, StreamResult,
150 return StreamResult::Dropped; in complete_read()
154 return StreamResult::Dropped; in complete_read()
157 StreamResult::Completed in complete_read()
173 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
221 Poll::Ready(Ok(StreamResult::Dropped)) in poll_produce()
315 ) -> Poll<wasmtime::Result<StreamResult>> { in poll_produce() argument
407 return StreamResult::Dropped; in complete_write()
411 return StreamResult::Dropped; in complete_write()
414 StreamResult::Completed in complete_write()
[all …]
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfutures_and_streams.rs486 pub enum StreamResult { enum
649 ) -> Poll<Result<StreamResult>>; in poll_produce() argument
674 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
692 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
710 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
729 ) -> Poll<Result<StreamResult>> { in poll_produce() argument
1082 ) -> Poll<Result<StreamResult>>; in poll_consume() argument
2275 StreamResult::Completed | StreamResult::Cancelled => ReadState::HostReady { in pipe_from_guest()
2318 StreamResult::Completed | StreamResult::Cancelled => WriteState::HostReady { in pipe_to_guest()
2878 StreamResult::Completed | StreamResult::Cancelled => {} in set_consumer()
[all …]
/wasmtime-44.0.1/crates/wasi-tls/src/p2/
H A Dio.rs14 DynInputStream, DynOutputStream, OutputStream, Pollable, StreamError, StreamResult,
240 fn write(&mut self, bytes: bytes::Bytes) -> StreamResult<()> { in write() argument
244 fn flush(&mut self) -> StreamResult<()> { in flush() argument
248 fn check_write(&mut self) -> StreamResult<usize> { in check_write()
285 fn write(&mut self, mut bytes: bytes::Bytes) -> StreamResult<()> { in write() argument
312 fn flush(&mut self) -> StreamResult<()> { in flush() argument
345 fn check_write(&mut self) -> StreamResult<usize> { in check_write()

12