Trait LocalAsyncStreamingSessionService 

pub trait LocalAsyncStreamingSessionService {
    // Required methods
    fn resolve(
        &self,
        auth_: BearerToken,
        dataset_rid: DatasetRid,
        request: ResolveStreamingSessionRequest,
    ) -> impl Future<Output = Result<ResolveStreamingSessionResponse, Error>>;
    fn heartbeat(
        &self,
        auth_: BearerToken,
        session_rid: StreamingSessionRid,
    ) -> impl Future<Output = Result<(), Error>>;
}

Required Methods

fn resolve( &self, auth_: BearerToken, dataset_rid: DatasetRid, request: ResolveStreamingSessionRequest, ) -> impl Future<Output = Result<ResolveStreamingSessionResponse, Error>>

fn heartbeat( &self, auth_: BearerToken, session_rid: StreamingSessionRid, ) -> impl Future<Output = Result<(), Error>>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors