equal
deleted
inserted
replaced
228 private void startInternal(long startNanos) { |
228 private void startInternal(long startNanos) { |
229 synchronized (configuration) { |
229 synchronized (configuration) { |
230 if (configuration.started) { |
230 if (configuration.started) { |
231 throw new IllegalStateException("Event stream can only be started once"); |
231 throw new IllegalStateException("Event stream can only be started once"); |
232 } |
232 } |
233 if (active) { |
233 if (active && configuration.startTime == null) { |
234 configuration.setStartNanos(startNanos); |
234 configuration.setStartNanos(startNanos); |
235 } |
235 } |
236 configuration.setStarted(true); |
236 configuration.setStarted(true); |
237 } |
237 } |
238 } |
238 } |