private void shutdownTransportChannel()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java [157:166]

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

    private void shutdownTransportChannel() {
        if (channel == null) {
            return;
        }
        try {
            channel.close();
        } catch (Exception e) {
            LOG.info("Shutting down TransportChannel failed.", e);
        }
    }