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

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

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,
}