@Test
public void searchWithResumption() {

    final String lastEventId = "my:lastEventId";
    final HttpHeader lastEventIdHeader = HttpHeader.parse("Last-Event-ID", lastEventId);
    final TestRouteResult routeResult = underTest.run(
            HttpRequest.GET(SEARCH_ROUTE)
                    .addHeader(acceptHeader)
                    .addHeader(lastEventIdHeader)
    );
    final CompletableFuture<Void> assertions =
            CompletableFuture.runAsync(() -> {
                routeResult.assertMediaType(MediaTypes.TEXT_EVENT_STREAM);
                routeResult.assertStatusCode(StatusCodes.OK);
            });
    final RetrieveThing retrieveThing = proxyActor.expectMsgClass(RetrieveThing.class);
    final Thing thing = Thing.newBuilder().setId(ThingId.of(lastEventId)).build();
    proxyActor.reply(RetrieveThingResponse.of(ThingId.of(lastEventId),
            thing,
            retrieveThing.getDittoHeaders()
    ));
    final StreamThings streamThings = proxyActor.expectMsgClass(StreamThings.class);
    replySourceRef(proxyActor, Source.lazily(Source::empty));
    assertions.join();
    assertThat(streamThings.getSortValues()).contains(JsonArray.of(JsonValue.of(lastEventId)));
}