@Test public void shouldCreationBeSuccessful() throws IOException { final TimeSeries timeSeries = new TimeSeries("id", 1, Arrays.asList(createListener()), Mockito.mock(Dispatcher.class)); timeSeries.close(); }
@Idempotent @Override public final void close() throws IOException { try { cleanup(); } finally { TimeSeries.IDS.remove(this.id); } }
TimeSeries implements Identifiable<String>, Closeable { @Idempotent @Override public final void close() throws IOException { try { cleanup(); } finally { TimeSeries.IDS.remove(this.id); } } }
TimeSeries implements Identifiable<String>, Closeable { @Idempotent @Override public final void close() throws IOException { try { cleanup(); } finally { TimeSeries.IDS.remove(this.id); } } TimeSeries(final String id, final int granularity, final List<? extends Listener> listeners, final Dispatcher dispatcher);  TimeSeries(final String id, final int granularity, final Optional<Long> latestTimestamp, final List<? extends Listener> listeners, final Dispatcher dispatcher); }
TimeSeries implements Identifiable<String>, Closeable { @Idempotent @Override public final void close() throws IOException { try { cleanup(); } finally { TimeSeries.IDS.remove(this.id); } } TimeSeries(final String id, final int granularity, final List<? extends Listener> listeners, final Dispatcher dispatcher);  TimeSeries(final String id, final int granularity, final Optional<Long> latestTimestamp, final List<? extends Listener> listeners, final Dispatcher dispatcher); @Override final String getId(); final boolean publish(final long timestamp, final int value); @Idempotent @Override final void close(); }
TimeSeries implements Identifiable<String>, Closeable { @Idempotent @Override public final void close() throws IOException { try { cleanup(); } finally { TimeSeries.IDS.remove(this.id); } } TimeSeries(final String id, final int granularity, final List<? extends Listener> listeners, final Dispatcher dispatcher);  TimeSeries(final String id, final int granularity, final Optional<Long> latestTimestamp, final List<? extends Listener> listeners, final Dispatcher dispatcher); @Override final String getId(); final boolean publish(final long timestamp, final int value); @Idempotent @Override final void close();  }