Searched refs:experimental_blockUntilDelivered (Results 1 – 2 of 2) sorted by relevance
73 message.send().experimental_blockUntilDelivered(TIMEOUT_MS, clock); in experimental_blockUntilDelivered_timesOut()88 assertThat(message.experimental_blockUntilDelivered(TIMEOUT_MS, clock)).isTrue(); in experimental_blockUntilDelivered_onAlreadyProcessed_succeeds()117 assertThat(message.experimental_blockUntilDelivered(TIMEOUT_MS, clock)).isTrue(); in experimental_blockUntilDelivered_markAsProcessedWhileBlocked_succeeds()
312 public synchronized boolean experimental_blockUntilDelivered(long timeoutMs) in experimental_blockUntilDelivered() method in PlayerMessage314 return experimental_blockUntilDelivered(timeoutMs, Clock.DEFAULT); in experimental_blockUntilDelivered()332 /* package */ synchronized boolean experimental_blockUntilDelivered(long timeoutMs, Clock clock) in experimental_blockUntilDelivered() method in PlayerMessage