fix failing test

Author: polbins

android/src/test/java/com/amplitude/android/ResponseHandlerTest.kt

@@ -21,13 +21,11 @@ import org.junit.Assert.assertEquals
 import org.junit.Assert.assertNotNull
 import org.junit.Assert.assertTrue
 import org.junit.Before
-import org.junit.Ignore
 import org.junit.Test
 import org.junit.runner.RunWith
 import org.robolectric.RobolectricTestRunner
 import java.util.concurrent.TimeUnit
 
-@Ignore
 @RunWith(RobolectricTestRunner::class)
 class ResponseHandlerTest {
     private lateinit var server: MockWebServer

core/src/main/java/com/amplitude/core/Amplitude.kt

@@ -156,10 +156,10 @@ open class Amplitude internal constructor(
         options: EventOptions? = null,
         callback: EventCallBack? = null,
     ): Amplitude {
-        options ?. let {
+        options?.let {
             event.mergeEventOptions(it)
         }
-        callback ?. let {
+        callback?.let {
             event.callback = it
         }
         process(event)

core/src/main/java/com/amplitude/core/platform/EventPipeline.kt

@@ -30,6 +30,15 @@ class EventPipeline(
     private var scheduled: Boolean
     var flushSizeDivider: AtomicInteger = AtomicInteger(1)
 
+    private val responseHandler by lazy {
+        storage.getResponseHandler(
+            this@EventPipeline,
+            amplitude.configuration,
+            scope,
+            amplitude.retryDispatcher,
+        )
+    }
+
     companion object {
         internal const val UPLOAD_SIG = "#!upload"
     }
@@ -116,7 +125,8 @@ class EventPipeline(
                         if (eventsString.isEmpty()) continue
 
                         val diagnostics = amplitude.diagnostics.extractDiagnostics()
-                        httpClient.upload(eventsString, diagnostics)
+                        val response = httpClient.upload(eventsString, diagnostics)
+                        responseHandler.handle(response, events, eventsString)
                     } catch (e: FileNotFoundException) {
                         e.message?.let {
                             amplitude.logger.warn("Event storage file not found: $it")