add new streams pattern
add disruptor support