Functional Web Socket pubsub channel