1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

use crate::completion_handler::CompletionHandler;
use crate::consumer::Consumer;
use crate::event_processor::EventProcessorActor;

pub struct ServiceBuilder<
    ConsumerT,
    TriggerT, // SqsMessage
    CompletedEventT,
    CompletionHandlerT,
> where
    ConsumerT: Consumer<TriggerT>,
    TriggerT: Send + Clone + Sync + 'static,
    CompletedEventT: Send + Clone + Sync + 'static,
    CompletionHandlerT: CompletionHandler<Message = TriggerT, CompletedEvent = CompletedEventT>,
{
    trigger_consumer: ConsumerT,
    event_processor: EventProcessorActor<TriggerT>,
    completion_handler: CompletionHandlerT,
}