Searched refs:TransmitOrigin (Results 1 – 2 of 2) sorted by relevance
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/ |
| H A D | future_stream_any.rs | 3 use crate::component::concurrent::futures_and_streams::{self, TransmitOrigin};
97 TransmitOrigin::Host => PayloadType::new_host::<T>(), in try_from_future_reader()
98 TransmitOrigin::GuestFuture(id, ty) => PayloadType::new_guest_future(store.0, id, ty), in try_from_future_reader()
99 TransmitOrigin::GuestStream(..) => bail!("not a future"), in try_from_future_reader()
269 TransmitOrigin::Host => PayloadType::new_host::<T>(), in try_from_stream_reader()
270 TransmitOrigin::GuestStream(id, ty) => PayloadType::new_guest_stream(store.0, id, ty), in try_from_stream_reader()
271 TransmitOrigin::GuestFuture(..) => bail!("not a stream"), in try_from_stream_reader()
|
| H A D | futures_and_streams.rs | 2109 pub(super) origin: TransmitOrigin,
2113 pub(super) enum TransmitOrigin { enum
2120 fn new(origin: TransmitOrigin) -> Self { in new()
2138 impl TransmitOrigin { implementation
2141 TransmitIndex::Future(ty) => TransmitOrigin::GuestFuture(id, ty), in guest()
2142 TransmitIndex::Stream(ty) => TransmitOrigin::GuestStream(id, ty), in guest()
2514 ) -> Result<TransmitOrigin> { in transmit_origin() argument
2532 let (_, read) = state.new_transmit(TransmitOrigin::Host)?; in new_transmit()
4300 .new_transmit(TransmitOrigin::guest(self.id().instance(), ty))?; in guest_new()
4624 origin: TransmitOrigin, in new_transmit() argument
|