Implements subscribe and unsubscribe functions that work with RiverOfNews, union and intersections.