public StreamQueryResponse query()

in src/main/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClient.java [372:387]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    public StreamQueryResponse query(StreamQuery streamQuery) throws BanyanDBException {
        checkState(this.streamServiceStub != null, "stream service is null");

        for (String group : streamQuery.groups) {
            MetadataCache.EntityMetadata em = this.metadataCache.findStreamMetadata(group, streamQuery.name);
            if (em != null) {
                final BanyandbStream.QueryResponse response = HandleExceptionsWith.callAndTranslateApiException(() ->
                        this.streamServiceBlockingStub
                                .withDeadlineAfter(this.getOptions().getDeadline(), TimeUnit.SECONDS)
                                .query(streamQuery.build(em)));
                return new StreamQueryResponse(response);
            }

        }
        throw new RuntimeException("No metadata found for the query");
    }