Struct StreamableHttpClientWorker 

#[non_exhaustive]
pub struct StreamableHttpClientWorker<C: StreamableHttpClient> {
    pub client: C,
    pub config: StreamableHttpClientTransportConfig,
}

Available on crate feature transport-streamable-http-client and (crate features client or server) only.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

client: C

config: StreamableHttpClientTransportConfig

Implementations

impl<C: StreamableHttpClient + Default> StreamableHttpClientWorker<C>

pub fn new_simple(url: impl Into<Arc<str>>) -> Self

impl<C: StreamableHttpClient> StreamableHttpClientWorker<C>

pub fn new(client: C, config: StreamableHttpClientTransportConfig) -> Self

Trait Implementations

impl<C: Clone + StreamableHttpClient> Clone for StreamableHttpClientWorker<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug + StreamableHttpClient> Debug for StreamableHttpClientWorker<C>

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

Formats the value using the given formatter.

impl<C: Default + StreamableHttpClient> Default for StreamableHttpClientWorker<C>

fn default() -> Self

Returns the “default value” for a type.

impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C>

type Role = RoleClient

Available on crate feature transport-worker only.

type Error = StreamableHttpError<<C as StreamableHttpClient>::Error>

Available on crate feature transport-worker only.

fn is_control_message(message: &ClientJsonRpcMessage) -> bool

Available on crate feature transport-worker only.

Return true to send this message through the separate control queue.

fn supports_request_cancellation() -> bool

Available on crate feature transport-worker only.

Return true to register outgoing requests for cancellation before they enter a queue.

fn err_closed() -> Self::Error

Available on crate feature transport-worker only.

fn err_join(e: JoinError) -> Self::Error

Available on crate feature transport-worker only.

fn config(&self) -> WorkerConfig

Available on crate feature transport-worker only.

async fn run( self, context: WorkerContext<Self>, ) -> Result<(), WorkerQuitReason<Self::Error>>

Available on crate feature transport-worker only.