Struct TestWrapper

pub struct TestWrapper<B, Req, Res> { /* private fields */ }

A generic backend wrapper that polls and executes jobs

Implementations

impl<B, Req, Res, Ctx> TestWrapper<B, Request<Req, Ctx>, Res>

where B: Backend<Request<Req, Ctx>, Res> + Send + Sync + 'static + Clone, Req: Send + 'static, Ctx: Send, B::Stream: Send + 'static + Stream<Item = Result<Option<Request<Req, Ctx>>, Error>> + Unpin,

A test wrapper to allow you to test without requiring a worker. Important for testing backends and jobs

Example

#[cfg(tests)]
mod tests {
   use crate::{
       error::Error, memory::MemoryStorage, mq::MessageQueue, service_fn::service_fn,
   };

   use super::*;

   async fn is_even(req: usize) -> Result<(), Error> {
       if req % 2 == 0 {
           Ok(())
       } else {
           Err(Error::Abort("Not an even number".to_string()))
       }
   }

   #[tokio::test]
   async fn test_accepts_even() {
       let backend = MemoryStorage::new();
       let (mut tester, poller) = TestWrapper::new_with_service(backend, service_fn(is_even));
       tokio::spawn(poller);
       tester.enqueue(42usize).await.unwrap();
       assert_eq!(tester.size().await.unwrap(), 1);
       let (_, resp) = tester.execute_next().await;
       assert_eq!(resp, Ok("()".to_string()));
   }
}

pub fn new_with_service<S>( backend: B, service: S, ) -> (Self, BoxFuture<'static, ()>)

where S: Service<Request<Req, Ctx>, Response = Res> + Send + 'static, B::Layer: Layer<S>, <<B as Backend<Request<Req, Ctx>, Res>>::Layer as Layer<S>>::Service: Service<Request<Req, Ctx>> + Send + 'static, <<<B as Backend<Request<Req, Ctx>, Res>>::Layer as Layer<S>>::Service as Service<Request<Req, Ctx>>>::Response: Send + Debug, <<<B as Backend<Request<Req, Ctx>, Res>>::Layer as Layer<S>>::Service as Service<Request<Req, Ctx>>>::Error: Send + Into<BoxDynError> + Sync, <<<B as Backend<Request<Req, Ctx>, Res>>::Layer as Layer<S>>::Service as Service<Request<Req, Ctx>>>::Future: Send + 'static,

Build a new instance provided a custom service

pub fn stop(self)

Stop polling

pub async fn execute_next(&mut self) -> (TaskId, Result<String, String>)

Gets the current state of results

Trait Implementations

impl<B: Debug, Req: Debug, Res: Debug> Debug for TestWrapper<B, Req, Res>

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

Formats the value using the given formatter.

impl<B, Req, Res, Ctx> Deref for TestWrapper<B, Request<Req, Ctx>, Res>

where B: Backend<Request<Req, Ctx>, Res>,

type Target = B

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<B, Req, Ctx, Res> DerefMut for TestWrapper<B, Request<Req, Ctx>, Res>

where B: Backend<Request<Req, Ctx>, Res>,

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.