Skip to content

Commit 4434e68

Browse files
committed
Flushing from a separate api file
1 parent 89c26cd commit 4434e68

2 files changed

Lines changed: 17 additions & 2 deletions

File tree

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
5+
6+
package io.opentelemetry.android.tools
7+
8+
import io.opentelemetry.sdk.common.CompletableResultCode
9+
10+
interface LogRecordFlusher {
11+
fun flushLogRecords(): CompletableResultCode
12+
}

instrumentation/crash/src/main/java/io/opentelemetry/android/instrumentation/crash/CrashReporter.kt

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ package io.opentelemetry.android.instrumentation.crash
88
import io.opentelemetry.android.OpenTelemetryRum
99
import io.opentelemetry.android.common.internal.utils.threadIdCompat
1010
import io.opentelemetry.android.instrumentation.common.EventAttributesExtractor
11+
import io.opentelemetry.android.tools.LogRecordFlusher
1112
import io.opentelemetry.api.common.Attributes
1213
import io.opentelemetry.context.Context
1314
import io.opentelemetry.semconv.ExceptionAttributes.EXCEPTION_MESSAGE
@@ -70,7 +71,9 @@ internal class CrashReporter(
7071
}
7172

7273
private fun waitForCrashFlush(openTelemetry: OpenTelemetryRum) {
73-
val flushResult = openTelemetry.sdkLoggerProvider.forceFlush()
74-
flushResult.join(10, TimeUnit.SECONDS)
74+
if (openTelemetry is LogRecordFlusher) {
75+
val flushResult = openTelemetry.flushLogRecords()
76+
flushResult.join(10, TimeUnit.SECONDS)
77+
}
7578
}
7679
}

0 commit comments

Comments
 (0)