Lines Matching refs:Stream
51 Stream, enumerator
108 Stream(TypeStreamTableIndex), enumerator
115 TransmitIndex::Stream(_) => TransmitKind::Stream, in kind()
124 TransmitIndex::Stream(i) => { in payload()
144 TransmitIndex::Stream(ty) => handle_table.stream_rep(ty, index), in get_mut_by_index_from()
1613 .new_transmit(TransmitKind::Stream, producer)?, in new()
1685 .set_consumer(self.id, TransmitKind::Stream, consumer) in pipe()
1770 store.host_drop_reader(id, TransmitKind::Stream) in stream_close()
1780 InterfaceType::Stream(src) => { in lift_index_to_stream()
1783 .table_for_transmit(TransmitIndex::Stream(src)); in lift_index_to_stream()
1803 InterfaceType::Stream(dst) => { in lower_stream_to_index()
1810 .table_for_transmit(TransmitIndex::Stream(dst)) in lower_stream_to_index()
1830 InterfaceType::Stream(ty) => { in typecheck()
2142 TransmitIndex::Stream(ty) => TransmitOrigin::GuestStream(id, ty), in guest()
2375 TransmitIndex::Stream(ty) => Event::StreamWrite { in host_drop_reader()
2393 TransmitKind::Stream => Event::StreamWrite { in host_drop_reader()
2474 TransmitIndex::Stream(ty) => Event::StreamRead { in host_drop_writer()
3160 TransmitIndex::Stream(ty) => table.stream_remove_writable(ty, writer)?, in guest_drop_writable()
3166 TransmitIndex::Stream(_) => store.host_drop_writer(id, None), in guest_drop_writable()
3280 (TransmitIndex::Stream(_), TransmitIndex::Stream(_)) => { in copy()
3374 TransmitIndex::Stream(ty) => types[types[ty].ty] in check_bounds()
3622 (ReturnCode::Dropped(_), TransmitIndex::Stream(_)) in guest_write()
3850 (ReturnCode::Dropped(_), TransmitIndex::Stream(_)) in guest_read()
4129 TransmitIndex::Stream(ty) => table.stream_remove_readable(ty, reader)?, in guest_drop_readable()
4133 TransmitIndex::Stream(_) => TransmitKind::Stream, in guest_drop_readable()
4258 self.guest_cancel_read(store, TransmitIndex::Stream(ty), async_, reader) in stream_cancel_read()
4270 self.guest_cancel_write(store, TransmitIndex::Stream(ty), async_, writer) in stream_cancel_write()
4291 self.guest_drop_readable(store, TransmitIndex::Stream(ty), reader) in stream_drop_readable()
4308 TransmitIndex::Stream(ty) => ( in guest_new()
4378 TransmitIndex::Stream(idx) => src_table.stream_remove_readable(idx, src_idx)?, in guest_transfer()
4386 TransmitIndex::Stream(idx) => dst_table.stream_insert_read(idx, rep), in guest_transfer()
4411 self.guest_new(store, TransmitIndex::Stream(ty)) in stream_new()
4443 TransmitIndex::Stream(src), in stream_transfer()
4444 TransmitIndex::Stream(dst), in stream_transfer()
4483 TransmitIndex::Stream(ty) => types[ty].instance, in table_for_transmit()
4523 TransmitIndex::Stream(ty) => Event::StreamWrite { in send_write_result()
4546 TransmitIndex::Stream(ty) => Event::StreamRead { in send_read_result()