Struct StreamingHandlerWithStateOnly 

pub struct StreamingHandlerWithStateOnly<F, S, Fut, R>
where
    F: Fn(State<Arc<S>>, StreamSender) -> Fut + Send + Sync,
    S: Send + Sync + 'static,
    Fut: Future<Output = R> + Send,
    R: IntoHandlerResult,
{ /* private fields */ }

Streaming handler that receives only injected state (no args)

Implementations

impl<F, S, Fut, R> StreamingHandlerWithStateOnly<F, S, Fut, R>

where F: Fn(State<Arc<S>>, StreamSender) -> Fut + Send + Sync, S: Send + Sync + 'static, Fut: Future<Output = R> + Send, R: IntoHandlerResult,

pub fn new( func: F, states: Arc<RwLock<HashMap<TypeId, Arc<dyn Any + Send + Sync>>>>, ) -> StreamingHandlerWithStateOnly<F, S, Fut, R>

Create a new streaming handler with state only

Trait Implementations

impl<F, S, Fut, R> StreamHandler for StreamingHandlerWithStateOnly<F, S, Fut, R>

where F: Fn(State<Arc<S>>, StreamSender) -> Fut + Send + Sync + 'static, S: Send + Sync + 'static, Fut: Future<Output = R> + Send + 'static, R: IntoHandlerResult + 'static,

fn call_streaming( &self, _args: &str, tx: StreamSender, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + '_>>

Call the streaming handler with JSON args and a stream sender.