public void close()

in rcomp-examples/kafka-appender/src/main/java/net/lr/reactive/components/appender/kafka/KafkaAppender.java [91:93]

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

    public void close() {
        toKafka.onComplete();
    }