boolean isEndOfStream()

in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java [431:433]

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

        boolean isEndOfStream(OUT record) {
            return endOfStreamSignalled || deliveryDeserializer.isEndOfStream(record);
        }