reactive-pg This repo gives an example of how to create your own publishers/subscribers & operators like map, etc.