This is an implementation of in-process pub/sub in Ruby with type checking at runtime.
It only allows subscribing to events with jobs to ensure that the subscriber blocks are fully asynchronous and cannot cause runtime exceptions.
This is the approach we use in production at rwx