andrewg
02/18/2017, 2:23 AMthrottleFirst could drop an emission during a window and the delay may emit after.
thing.changeNotifications()
.throttleFirst(windowSeconds, TimeUnit.SECONDS)
.delay(windowSeconds, TimeUnit.SECONDS)
.subscribe { thingSaver.save(thing) }