Trait Alias AlignedMessageStream

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