public BlockingGrpcPubSubSubscriber()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/BlockingGrpcPubSubSubscriber.java [50:63]

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

    public BlockingGrpcPubSubSubscriber(
            String projectSubscriptionName,
            ManagedChannel channel,
            SubscriberGrpc.SubscriberBlockingStub stub,
            PullRequest pullRequest,
            int retries,
            Duration timeout) {
        this.projectSubscriptionName = projectSubscriptionName;
        this.channel = channel;
        this.stub = stub;
        this.retries = retries;
        this.timeout = timeout;
        this.pullRequest = pullRequest;
    }