Struct ModelSocket 

pub struct ModelSocket { /* private fields */ }

Implementations

impl ModelSocket

pub fn new<RX, TX, T>(transport: T) -> Result<Self, ModelSocketError>

where RX: Stream<Item = Result<MSEvent, ModelSocketError>> + Send + Unpin + 'static, TX: Sink<MSRequest, Error = ModelSocketError> + Send + 'static, T: MSTransport<RX, TX>,

pub async fn connect( url: &str, api_key: Option<&str>, ) -> Result<Self, ModelSocketError>

impl ModelSocket

pub async fn open( &self, model: &str, opts: Option<OpenOpts>, ) -> Result<Seq, ModelSocketError>

Trait Implementations

impl Clone for ModelSocket

fn clone(&self) -> ModelSocket

Returns a duplicate of the value.

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

Performs copy-assignment from source.