Trait Alias MessageStreamInner 

trait MessageStreamInner<M> = Stream<Item = MessageStreamItemInner<M>> + Send;