Easy integration of mubsub into socketstream