If using simulated time simulate waiting for 10 seconds. This is intended for internal testing only.
(ILocalCluster cluster)
| 483 | * If using simulated time simulate waiting for 10 seconds. This is intended for internal testing only. |
| 484 | */ |
| 485 | public static void simulateWait(ILocalCluster cluster) throws InterruptedException { |
| 486 | if (Time.isSimulating()) { |
| 487 | cluster.advanceClusterTime(10); |
| 488 | Thread.sleep(100); |
| 489 | } |
| 490 | } |
| 491 | |
| 492 | /** |
| 493 | * Get all of the tuples from a given component on the default stream. |
no test coverage detected