Struct wasmcloud_core::chunking::ChunkEndpoint

pub struct ChunkEndpoint { /* private fields */ }

Implementations

impl ChunkEndpoint

pub fn new(lattice: &str, js: Context) -> Self

pub fn with_client( lattice: &str, nc: Client, domain: Option<impl AsRef<str>> ) -> Self

pub async fn get_unchunkified(&self, inv_id: &str) -> Result<Vec<u8>>

load the message after de-chunking

pub async fn get_unchunkified_response(&self, inv_id: &str) -> Result<Vec<u8>>

load response after de-chunking

pub async fn chunkify( &self, inv_id: &str, bytes: impl AsyncRead + Unpin ) -> Result<()>

chunkify a message

pub async fn chunkify_response( &self, inv_id: &str, bytes: impl AsyncRead + Unpin ) -> Result<()>

chunkify a portion of a response

Trait Implementations

impl Clone for ChunkEndpoint

fn clone(&self) -> ChunkEndpoint

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChunkEndpoint

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.