DelegatingAsyncEventStore implements EventStoreAsync { @Override public final void close() { delegate.close(); } DelegatingAsyncEventStore(@NotNull final Executor executor, @NotNull final EventStore delegate); @Override final CompletableFuture<Void> open(); @Override final void close(); @Override final CompletableFuture<CommonEvent> readEvent(final StreamId streamId, final long eventNumber); @Override final CompletableFuture<StreamEventsSlice> readEventsForward(final StreamId streamId,
            final long start, final int count); @Override final CompletableFuture<StreamEventsSlice> readEventsBackward(final StreamId streamId,
            final long start, final int count); @Override final CompletableFuture<Void> deleteStream(final StreamId streamId, final long expected,
            final boolean hardDelete); @Override final CompletableFuture<Void> deleteStream(final StreamId streamId, final boolean hardDelete); @Override final CompletableFuture<Long> appendToStream(final StreamId streamId, final long expectedVersion,
            final List<CommonEvent> toAppend); @Override final CompletableFuture<Long> appendToStream(final StreamId streamId, final long expectedVersion,
            final CommonEvent... events); @Override final CompletableFuture<Long> appendToStream(final StreamId streamId,
            final List<CommonEvent> toAppend); @Override final CompletableFuture<Long> appendToStream(final StreamId streamId,
            final CommonEvent... events); @Override final CompletableFuture<Boolean> streamExists(final StreamId streamId); @Override final CompletableFuture<StreamState> streamState(final StreamId streamId); @Override final boolean isSupportsCreateStream(); @Override CompletableFuture<Void> createStream(final StreamId streamId);  }
@Test public void testClose() throws Exception { testee.close(); verify(delegate).close(); }