equal
deleted
inserted
replaced
46 /* |
46 /* |
47 * Purpose of this class is to simplify the implementation of |
47 * Purpose of this class is to simplify the implementation of |
48 * an event stream. |
48 * an event stream. |
49 */ |
49 */ |
50 abstract class AbstractEventStream implements EventStream { |
50 abstract class AbstractEventStream implements EventStream { |
51 private final static AtomicLong counter = new AtomicLong(1); |
51 private final static AtomicLong counter = new AtomicLong(0); |
52 |
52 |
53 private final Object terminated = new Object(); |
53 private final Object terminated = new Object(); |
54 private final Runnable flushOperation = () -> dispatcher().runFlushActions(); |
54 private final Runnable flushOperation = () -> dispatcher().runFlushActions(); |
55 private final AccessControlContext accessControllerContext; |
55 private final AccessControlContext accessControllerContext; |
56 private final StreamConfiguration configuration = new StreamConfiguration(); |
56 private final StreamConfiguration configuration = new StreamConfiguration(); |