Trait Alias AlignedMessageStream 

trait AlignedMessageStream = Stream<Item = StreamExecutorResult<AlignedMessage>> + Send;