Grab PriorityQueue from Rx
Our SemaphoreSubject now dequeues in priority order
Rename the file to match
ScheduledSubject is omgsekrit