Lines Matching refs:stream

48     // make a stream read/write combo with the `id` specified.
49     stream-new(u32),
50     // take a stream readable end through the `stream-take` import.
51     stream-take(u32),
52     // pass the stream specified to this component's `stream-receive` import.
53     stream-give(u32),
54     // drop the stream end identified
55     stream-drop-readable(u32),
56     stream-drop-writable(u32),
58     stream-write-ready(stream-ready-payload),
59     stream-read-ready(stream-ready-payload),
60     stream-write-pending(stream-write-payload),
61     stream-read-pending(stream-read-payload),
62     stream-write-dropped(stream-write-payload),
63     stream-read-dropped(stream-read-payload),
64     stream-cancel-write(u32),
65     stream-cancel-read(u32),
66     stream-write-assert-complete(stream-read-payload),
67     stream-write-assert-dropped(stream-read-payload),
68     stream-read-assert-complete(stream-write-payload),
69     stream-read-assert-dropped(u32),
79   record stream-ready-payload {
80     %stream: u32,
86   record stream-write-payload {
87     %stream: u32,
92   record stream-read-payload {
93     %stream: u32,
102   get-commands: func(s: scope) -> stream<command>;
129   // Remove the stream reader `id` from this component's state and return it.
130   stream-take: func(id: u32) -> stream<u32>;
131   // Receive a stream from another component.
132   stream-receive: func(id: u32, f: stream<u32>);