testcontainers 0.27.3

A library for integration-testing against docker containers from within Rust.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use futures::{future::BoxFuture, FutureExt};

use crate::core::logs::LogFrame;

pub mod logging_consumer;

/// Log consumer is a trait that allows to consume log frames.
/// Consumers will be called for each log frame that is produced by the container for the whole lifecycle of the container.
pub trait LogConsumer: Send + Sync {
    fn accept<'a>(&'a self, record: &'a LogFrame) -> BoxFuture<'a, ()>;
}

impl<F> LogConsumer for F
where
    F: Fn(&LogFrame) + Send + Sync,
{
    fn accept<'a>(&'a self, record: &'a LogFrame) -> BoxFuture<'a, ()> {
        // preferably to spawn blocking task
        async move {
            self(record);
        }
        .boxed()
    }
}