59 public Event waitFor(String expectedStreamId, EventKind expectedEventKind) {
60 long end = System.currentTimeMillis() + 5000;
63 if (expectedStreamId.equals(lastStreamId) && expectedEventKind.equals(lastEvent.getKind())) {
64 Event event = lastEvent;
69 long timeout =
end - System.currentTimeMillis();
75 }
catch (InterruptedException e) {
80 throw new RuntimeException(
"Expected event: " + expectedStreamId +
", " + expectedEventKind);