Lines Matching refs:stream

70     read-stream(string),
71     read-stream-zero,
73     write-stream(string),
74     write-stream-zero,
78   exchange: async func(control: stream<control>,
79                  caller-stream: stream<string>,
81 …          caller-future2: future<string>) -> tuple<stream<string>, future<string>, future<string>>;
111 interface run-stream {
112   produce-then-error: func(times: u32) -> stream;
119 interface unit-stream {
120   run: async func(count: u32) -> stream;
123 interface resource-stream {
128   foo: async func(count: u32) -> stream<x>;
132   read-stream: async func(rx: stream<u8>, expected: list<u8>);
171   start: async func(s: stream<u8>, expected: list<u8>) -> tuple<stream<u8>, list<u8>>;
175 …start: async func(s: stream<u8>, s-expected: list<u8>, f: future<u8>, f-expected: u8) -> tuple<str…
182 interface closed-stream {
183   get: func() -> stream<u8>;
192   short-reads: async func(s: stream<thing>) -> stream<thing>;
276 world error-context-stream-callee {
277   export run-stream;
281 world error-context-stream-caller {
282   import run-stream;
296 world unit-stream-caller {
297   import unit-stream;
301 world unit-stream-callee {
302   export unit-stream;
305 world read-resource-stream {
306   import resource-stream;
360 world closed-stream-guest {
361   export closed-stream;