Makes a { publisher, subscriber } pair for doing efficient distributed pub/sub supporting both "each" and "latest" iteration of published values.