Sp4.sc1.stream process

Basic implementations of the pub/sub entities.