additional review comments

Author: tanderson-ld

sdk/@launchdarkly/observability-android/lib/src/main/kotlin/com/launchdarkly/observability/replay/CaptureSource.kt

@@ -19,9 +19,9 @@ import android.view.ViewGroup
 import androidx.compose.ui.platform.ComposeView
 import androidx.compose.ui.semantics.SemanticsNode
 import androidx.compose.ui.semantics.SemanticsOwner
+import com.launchdarkly.observability.coroutines.DispatcherProviderHolder
 import io.opentelemetry.android.session.SessionManager
 import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.flow.asSharedFlow
@@ -109,7 +109,7 @@ class CaptureSource(
     /**
      * Internal capture routine.
      */
-    private suspend fun doCapture(): CaptureEvent? = withContext(Dispatchers.Main) {
+    private suspend fun doCapture(): CaptureEvent? = withContext(DispatcherProviderHolder.current.main) {
         try {
             if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                 val activity = _mostRecentActivity ?: return@withContext null // return if no activity
@@ -149,7 +149,7 @@ class CaptureSource(
                                 val session = sessionManager.getSessionId()
 
                                 if (result == PixelCopy.SUCCESS) {
-                                    CoroutineScope(Dispatchers.Default).launch {
+                                    CoroutineScope(DispatcherProviderHolder.current.default).launch {
                                         try {
                                             val postMask = if (maskMatchers.isNotEmpty()) {
                                                 maskSensitiveRects(bitmap, sensitiveComposeRects)

sdk/@launchdarkly/observability-android/lib/src/main/kotlin/com/launchdarkly/observability/replay/InteractionSource.kt

@@ -24,7 +24,7 @@ class InteractionSource(
     // Using tryEmit() instead of emit() to avoid blocking the UI thread
     private val _captureEventFlow = MutableSharedFlow<InteractionEvent>(
         extraBufferCapacity = 64, // Buffer up to 64 events before dropping
-        onBufferOverflow = BufferOverflow.DROP_LATEST
+        onBufferOverflow = BufferOverflow.DROP_OLDEST
     )
 
     // Interactions from the most recent window will be reported periodically on this flow.
@@ -63,7 +63,7 @@ class InteractionSource(
         val pointerIndex = motionEvent.findPointerIndex(_watchedPointerId)
         val eventTimeReference = System.currentTimeMillis() - SystemClock.uptimeMillis()
 
-        when (motionEvent.action) {
+        when (motionEvent.actionMasked) {
             MotionEvent.ACTION_DOWN -> {
                 val interaction = InteractionEvent(
                     action = motionEvent.action,

sdk/@launchdarkly/observability-android/lib/src/main/kotlin/com/launchdarkly/observability/replay/ReplayInstrumentation.kt

@@ -1,11 +1,11 @@
 package com.launchdarkly.observability.replay
 
+import com.launchdarkly.observability.coroutines.DispatcherProviderHolder
 import com.launchdarkly.observability.interfaces.LDExtendedInstrumentation
 import io.opentelemetry.android.instrumentation.InstallationContext
 import io.opentelemetry.api.logs.Logger
 import io.opentelemetry.sdk.logs.LogRecordProcessor
 import io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor
-import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.delay
@@ -82,7 +82,7 @@ class ReplayInstrumentation(
 
         // TODO: O11Y-621 - don't use global scope
         // TODO: O11Y-621 - shutdown procedure and cleanup of dispatched jobs
-        GlobalScope.launch(Dispatchers.Default) {
+        GlobalScope.launch(DispatcherProviderHolder.current.default) {
             _captureSource.captureFlow.collect { capture ->
                 _otelLogger.logRecordBuilder()
                     .setAttribute("event.domain", "media")
@@ -95,7 +95,7 @@ class ReplayInstrumentation(
             }
         }
 
-        GlobalScope.launch(Dispatchers.Default) {
+        GlobalScope.launch(DispatcherProviderHolder.current.default) {
             _interactionSource.captureFlow.collect{ interaction->
                 // Serialize positions list to JSON using StringBuilder for performance
                 val positionsJson = StringBuilder().apply {
@@ -163,7 +163,7 @@ class ReplayInstrumentation(
 
     private fun internalStartCapture() {
         // TODO: O11Y-621 - don't use global scope
-        _captureJob = GlobalScope.launch(Dispatchers.Default) {
+        _captureJob = GlobalScope.launch(DispatcherProviderHolder.current.default) {
             try {
                 while (true) {
                     // Perform capture