@Test
public void resumeAtStart() {

    final JsonArray sortValues = JsonArray.of(997, "t:3");
    startTestSearchSource(null, sortValues);
    sinkProbe.request(200L);
    conciergeForwarderProbe.expectMsg(streamThings(sortValues));
    conciergeForwarderProbe.reply(materializeSourceProbe());
    sourceProbe.expectRequest();
    sourceProbe.sendNext("t:2").sendComplete();
    conciergeForwarderProbe.expectMsg(retrieveThing("t:2", null));
    conciergeForwarderProbe.reply(retrieveThingResponse(2));
    sinkProbe.expectNext(getThing(2).toJson())
            .expectComplete();
}