ConnectionEntry implements Immutable { public void complete(final Response<?, ?> response) { callback.accept(response); } ConnectionEntry(final Request<?, ?> request, final Consumer<Response<?, ?>> callback, final long now);   ConnectionEntry(final ConnectionEntry entry); final Consumer<Response<?, ?>> getCallback(); final Request<?, ?> getRequest(); void complete(final Response<?, ?> response); final long getEnqueuedTicks(); @Override final String toString();  }
@Test public void testComplete() { entry.complete(mockResponse); verify(mockCallback).accept(mockResponse); }