SlaveStateQueue.StateChangeEvent
poll(long timeout, TimeUnit unit)
pollNow()
take()
Stream<SlaveStateQueue.StateChangeEvent>
streamUntilClosed()