Trait fluvio_service::FlvService[−][src]

pub trait FlvService<S> where
    S: AsyncRead + AsyncWrite + Unpin + Send, {
    type Request;
    type Context;
#[must_use]    fn respond<'async_trait>(
        self: Arc<Self>, 
        context: Self::Context, 
        socket: InnerFlvSocket<S>
    ) -> Pin<Box<dyn Future<Output = Result<(), FlvSocketError>> + Send + 'async_trait>>
    where
        InnerFlvSink<S>: ZeroCopyWrite,
        Self: 'async_trait;
}

Trait for responding to kf service Request -> Response is type specific Each response is responsible for sending back to socket

Associated Types

type Request[src]

type Context[src]

Loading content...

Required methods

#[must_use]fn respond<'async_trait>(
    self: Arc<Self>,
    context: Self::Context,
    socket: InnerFlvSocket<S>
) -> Pin<Box<dyn Future<Output = Result<(), FlvSocketError>> + Send + 'async_trait>> where
    InnerFlvSink<S>: ZeroCopyWrite,
    Self: 'async_trait, [src]

respond to request

Loading content...

Implementors

Loading content...