pub struct CallContext { /* private fields */ }
Expand description
A CallContext is a way to bucket calls together with the same memory and configuration.
Implementations§
Source§impl CallContext
impl CallContext
Sourcepub fn get_import(&self, namespace: &str, operation: &str) -> Option<u32>
pub fn get_import(&self, namespace: &str, operation: &str) -> Option<u32>
Get the import id for a given namespace and operation.
Sourcepub fn get_export(&self, namespace: &str, operation: &str) -> Option<u32>
pub fn get_export(&self, namespace: &str, operation: &str) -> Option<u32>
Get the export id for a given namespace and operation.
Sourcepub fn get_exports(&self) -> Vec<String>
pub fn get_exports(&self) -> Vec<String>
Get a list of the exports for this context.
Sourcepub fn dump_operations(&self)
pub fn dump_operations(&self)
A utility function to dump the operation list.
Trait Implementations§
Source§impl Debug for CallContext
impl Debug for CallContext
Source§impl RSocket for CallContext
impl RSocket for CallContext
Source§fn fire_and_forget(&self, payload: RawPayload) -> BoxMono<(), PayloadError>
fn fire_and_forget(&self, payload: RawPayload) -> BoxMono<(), PayloadError>
Fire and Forget interaction model of RSocket.
Source§fn request_response(
&self,
payload: RawPayload,
) -> BoxMono<RawPayload, PayloadError>
fn request_response( &self, payload: RawPayload, ) -> BoxMono<RawPayload, PayloadError>
Request-Response interaction model of RSocket.
Source§fn request_stream(
&self,
payload: RawPayload,
) -> BoxFlux<RawPayload, PayloadError>
fn request_stream( &self, payload: RawPayload, ) -> BoxFlux<RawPayload, PayloadError>
Request-Stream interaction model of RSocket.
Source§fn request_channel<T: Stream<Item = Result<RawPayload, PayloadError>> + ConditionallySend + Unpin + 'static>(
&self,
stream: T,
) -> BoxFlux<RawPayload, PayloadError>
fn request_channel<T: Stream<Item = Result<RawPayload, PayloadError>> + ConditionallySend + Unpin + 'static>( &self, stream: T, ) -> BoxFlux<RawPayload, PayloadError>
Request-Channel interaction model of RSocket.
Auto Trait Implementations§
impl Freeze for CallContext
impl !RefUnwindSafe for CallContext
impl Send for CallContext
impl Sync for CallContext
impl Unpin for CallContext
impl !UnwindSafe for CallContext
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more