equal
deleted
inserted
replaced
90 es.setReuse(reuse); |
90 es.setReuse(reuse); |
91 es.setOrdered(true); |
91 es.setOrdered(true); |
92 es.onEvent(e -> { |
92 es.onEvent(e -> { |
93 Instant endTime = e.getEndTime(); |
93 Instant endTime = e.getEndTime(); |
94 if (endTime.isBefore(timestamp.get())) { |
94 if (endTime.isBefore(timestamp.get())) { |
95 throw new Error("Events are not ordered! Reues = " + reuse); |
95 throw new Error("Events are not ordered! Reuse = " + reuse); |
96 } |
96 } |
97 timestamp.set(endTime); |
97 timestamp.set(endTime); |
98 }); |
98 }); |
99 es.start(); |
99 es.start(); |
100 } |
100 } |
116 } |
116 } |
117 timestamp.set(endTime); |
117 timestamp.set(endTime); |
118 }); |
118 }); |
119 es.start(); |
119 es.start(); |
120 if (!unoreded.get()) { |
120 if (!unoreded.get()) { |
121 throw new Exception("Expected at least some events to be out of order! Reues = " + reuse); |
121 throw new Exception("Expected at least some events to be out of order! Reuse = " + reuse); |
122 } |
122 } |
123 } |
123 } |
124 } |
124 } |
125 } |
125 } |
126 |
126 |