Skip to content

Commit 5d5adb0

Browse files
committed
A minor refactoring
1 parent b7c8200 commit 5d5adb0

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

sdk/logs/src/main/java/io/opentelemetry/sdk/logs/LogRecordProcessor.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,17 +40,15 @@ static LogRecordProcessor composite(LogRecordProcessor... processors) {
4040
*/
4141
static LogRecordProcessor composite(Iterable<LogRecordProcessor> processors) {
4242
List<LogRecordProcessor> processorList = new ArrayList<>();
43-
BatchLogRecordProcessor batchProcessor = null;
43+
List<BatchLogRecordProcessor> batchProcessors = new ArrayList<>();
4444
for (LogRecordProcessor processor : processors) {
4545
if (!BatchLogRecordProcessor.class.equals(processor.getClass())) {
4646
processorList.add(processor);
4747
} else {
48-
batchProcessor = (BatchLogRecordProcessor) processor;
48+
batchProcessors.add((BatchLogRecordProcessor) processor);
4949
}
5050
}
51-
if (batchProcessor != null) {
52-
processorList.add(batchProcessor);
53-
}
51+
processorList.addAll(batchProcessors);
5452

5553
if (processorList.isEmpty()) {
5654
return NoopLogRecordProcessor.getInstance();

0 commit comments

Comments
 (0)