SearchSource { public static SearchSourceBuilder newBuilder() { return new SearchSourceBuilder(); } SearchSource(final ActorRef pubSubMediator,
            final ActorRef conciergeForwarder,
            final Duration thingsAskTimeout,
            final Duration searchAskTimeout,
            @Nullable final JsonFieldSelector fields,
            final JsonFieldSelector sortFields,
            final StreamThings streamThings,
            final String lastThingId); static SearchSourceBuilder newBuilder(); Source<JsonObject, NotUsed> start(final Consumer<ResumeSourceBuilder<?, ?>> configurer); Source<Pair<String, JsonObject>, NotUsed> startAsPair(final Consumer<ResumeSourceBuilder<?, ?>> configurer);  }
@Test public void clientError() { startTestSearchSource(null, null); sinkProbe.request(1L); conciergeForwarderProbe.expectMsg(streamThings(null)); conciergeForwarderProbe.reply(InvalidRqlExpressionException.newBuilder().build()); assertThat(sinkProbe.expectError()).isInstanceOf(InvalidRqlExpressionException.class); }