diff --git a/example/src/main/java/com/basistheory/android/example/view/dual_write/DualWriteFragment.kt b/example/src/main/java/com/basistheory/android/example/view/dual_write/DualWriteFragment.kt
new file mode 100644
index 00000000..5e9ef82b
--- /dev/null
+++ b/example/src/main/java/com/basistheory/android/example/view/dual_write/DualWriteFragment.kt
@@ -0,0 +1,80 @@
+package com.basistheory.android.example.view.dual_write
+
+import android.os.Bundle
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import androidx.fragment.app.Fragment
+import androidx.fragment.app.viewModels
+import com.basistheory.android.example.databinding.FragmentDualWriteBinding
+import com.basistheory.android.example.viewmodel.CardFragmentViewModel
+import com.basistheory.android.service.HttpMethod
+
+class DualWriteFragment : Fragment() {
+    private val binding: FragmentDualWriteBinding by lazy {
+        FragmentDualWriteBinding.inflate(layoutInflater)
+    }
+
+    private val viewModel: CardFragmentViewModel by viewModels()
+
+    override fun onCreateView(
+        inflater: LayoutInflater,
+        container: ViewGroup?,
+        savedInstanceState: Bundle?
+    ): View {
+        super.onCreateView(inflater, container, savedInstanceState)
+        binding.lifecycleOwner = this
+        binding.viewModel = viewModel
+
+        binding.cvc.cardNumberElement = binding.cardNumber
+
+        binding.postButton.setOnClickListener { createPaymentMethod() }
+        binding.autofillButton.setOnClickListener { autofill() }
+
+        setValidationListeners()
+
+        return binding.root
+    }
+
+
+    private fun autofill() {
+        binding.cardNumber.setText("4242424242424242")
+        binding.expirationDate.setText("12/25")
+        binding.cvc.setText("123")
+    }
+
+    private fun createPaymentMethod() = viewModel.client.post(
+        "https://api.stripe.com/v1/payment_methods", headers = mapOf(
+            "Authorization" to "Bearer {{ STRIPE'S API KEY}}",
+            "Content-Type" to "application/x-www-form-urlencoded"
+        ), object {
+            val type = "card"
+            val billing_details = object {
+                val name = "Peter Panda"
+            }
+            val card = object {
+                val number = binding.cardNumber
+                val exp_month = binding.expirationDate.month()
+                val exp_year = binding.expirationDate.year()
+                val cvc = binding.cvc
+            }
+        }
+    ).observe(viewLifecycleOwner) {}
+
+    /**
+     * demonstrates how an application could potentially wire up custom validation behaviors
+     */
+    private fun setValidationListeners() {
+        binding.cardNumber.addChangeEventListener {
+            viewModel.cardNumber.observe(it)
+        }
+
+        binding.expirationDate.addChangeEventListener {
+            viewModel.cardExpiration.observe(it)
+        }
+
+        binding.cvc.addChangeEventListener {
+            viewModel.cardCvc.observe(it)
+        }
+    }
+}
diff --git a/example/src/main/java/com/basistheory/android/example/viewmodel/ApiViewModel.kt b/example/src/main/java/com/basistheory/android/example/viewmodel/ApiViewModel.kt
index 7a087dcb..1e6718ff 100644
--- a/example/src/main/java/com/basistheory/android/example/viewmodel/ApiViewModel.kt
+++ b/example/src/main/java/com/basistheory/android/example/viewmodel/ApiViewModel.kt
@@ -10,9 +10,10 @@ import com.basistheory.android.example.BuildConfig
 import com.basistheory.android.example.R
 import com.basistheory.android.example.util.prettyPrintJson
 import com.basistheory.android.service.BasisTheoryElements
+import com.basistheory.android.service.HttpMethod
 import com.basistheory.android.service.ProxyRequest
 
-open class ApiViewModel(application: Application): AndroidViewModel(application) {
+open class ApiViewModel(application: Application) : AndroidViewModel(application) {
     private val _errorMessage = MutableLiveData<String?>(null)
     val errorMessage: LiveData<String?>
         get() = _errorMessage
@@ -30,6 +31,74 @@ open class ApiViewModel(application: Application): AndroidViewModel(application)
         .apiKey(BuildConfig.BASIS_THEORY_API_KEY)
         .build()
 
+
+    val client = Client()
+
+    inner class Client {
+        fun post(
+            url: String,
+            headers: Map<String, String>,
+            body: Any
+        ): LiveData<Any> = performRequest(HttpMethod.POST, url, headers, body)
+
+        fun get(
+            url: String,
+            headers: Map<String, String>
+        ): LiveData<Any> = performRequest(HttpMethod.GET, url, headers, null)
+
+        fun put(
+            url: String,
+            headers: Map<String, String>,
+            body: Any
+        ): LiveData<Any> = performRequest(HttpMethod.PUT, url, headers, body)
+
+        fun patch(
+            url: String,
+            headers: Map<String, String>,
+            body: Any
+        ): LiveData<Any> = performRequest(HttpMethod.PATCH, url, headers, body)
+
+        fun delete(
+            url: String,
+            headers: Map<String, String>
+        ): LiveData<Any> = performRequest(HttpMethod.DELETE, url, headers, null)
+
+
+        private fun performRequest(
+            method: HttpMethod,
+            url: String,
+            headers: Map<String, String>,
+            body: Any?
+        ): LiveData<Any> = liveData {
+            _errorMessage.value = null
+            _result.value = null
+
+            runCatching {
+                when (method) {
+                    HttpMethod.GET -> bt.client.get(url, headers)
+                    HttpMethod.POST -> bt.client.post(url, body!!, headers)
+                    HttpMethod.PUT -> bt.client.put(url, body!!, headers)
+                    HttpMethod.PATCH -> bt.client.patch(url, body!!, headers)
+                    HttpMethod.DELETE -> bt.client.delete(url, headers)
+                }
+            }.fold(
+                onSuccess = {
+                    if (it != null) {
+                        _result.value = it.prettyPrintJson()
+                        emit(it)
+                    }
+                },
+                onFailure = {
+                    _errorMessage.value = getApplication<Application>()
+                        .resources
+                        .getString(R.string.tokenize_error, it)
+                }
+            )
+        }
+
+    }
+
+
     fun tokenize(payload: Any): LiveData<Any> = liveData {
         _errorMessage.value = null
         _result.value = null
diff --git a/example/src/main/res/layout/fragment_dual_write.xml b/example/src/main/res/layout/fragment_dual_write.xml
new file mode 100644
index 00000000..af675805
--- /dev/null
+++ b/example/src/main/res/layout/fragment_dual_write.xml
@@ -0,0 +1,109 @@
+<?xml version="1.0" encoding="utf-8"?>
+<layout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools">
+
+    <data>
+
+        <import type="android.view.View" />
+
+        <variable
+            name="viewModel"
+            type="com.basistheory.android.example.viewmodel.CardFragmentViewModel" />
+    </data>
+
+    <androidx.constraintlayout.widget.ConstraintLayout
+        android:layout_width="match_parent"
+        android:layout_height="match_parent"
+        tools:context="com.basistheory.android.example.view.dual_write.DualWriteFragment">
+
+        <ScrollView
+            android:layout_width="match_parent"
+            android:layout_height="match_parent"
+            android:background="@color/white">
+
+            <LinearLayout
+                android:layout_width="match_parent"
+                android:layout_height="wrap_content"
+                android:layout_margin="20dp"
+                android:orientation="vertical">
+
+                <com.basistheory.android.view.CardNumberElement
+                    android:id="@+id/card_number"
+                    android:layout_width="match_parent"
+                    android:layout_height="wrap_content"
+                    android:background="@drawable/rounded_edit_text"
+                    android:padding="5dp"
+                    android:hint="@string/card_number"
+                    android:textColor="@{ viewModel.cardNumber.isInvalid ? @color/red : @color/gray_800 }" />
+
+                <com.basistheory.android.view.CardExpirationDateElement
+                    android:id="@+id/expiration_date"
+                    android:layout_width="match_parent"
+                    android:layout_height="wrap_content"
+                    android:layout_marginTop="20dp"
+                    android:background="@drawable/rounded_edit_text"
+                    android:padding="5dp"
+                    android:hint="@string/expiration_date"
+                    android:textColor="@{ viewModel.cardExpiration.isInvalid ? @color/red : @color/gray_800 }" />
+
+                <com.basistheory.android.view.CardVerificationCodeElement
+                    android:id="@+id/cvc"
+                    android:layout_width="match_parent"
+                    android:layout_height="wrap_content"
+                    android:layout_marginTop="20dp"
+                    android:background="@drawable/rounded_edit_text"
+                    android:padding="5dp"
+                    android:hint="@string/cvc"
+                    android:textColor="@{ viewModel.cardCvc.isInvalid ? @color/red : @color/gray_800 }" />
+
+                <LinearLayout
+                    android:layout_width="wrap_content"
+                    android:layout_height="wrap_content"
+                    android:orientation="horizontal">
+
+                    <Button
+                        android:id="@+id/post_button"
+                        android:layout_width="wrap_content"
+                        android:layout_height="wrap_content"
+                        android:layout_marginTop="20dp"
+                        android:backgroundTint="@color/primary"
+                        android:enabled="@{ viewModel.canSubmit }"
+                        android:text="@string/post" />
+
+                    <Button
+                        android:id="@+id/autofill_button"
+                        android:layout_width="wrap_content"
+                        android:layout_height="wrap_content"
+                        android:layout_marginStart="20dp"
+                        android:layout_marginTop="20dp"
+                        android:backgroundTint="@color/primary"
+                        android:text="@string/autofill" />
+
+                </LinearLayout>
+
+                <TextView
+                    android:id="@+id/error_message"
+                    android:layout_width="match_parent"
+                    android:layout_height="wrap_content"
+                    android:layout_marginTop="20dp"
+                    android:fontFamily="monospace"
+                    android:text="@{ viewModel.errorMessage }"
+                    android:textColor="@color/red"
+                    android:visibility="@{ viewModel.errorMessage != null ? View.VISIBLE : View.GONE }" />
+
+                <TextView
+                    android:id="@+id/result"
+                    android:layout_width="match_parent"
+                    android:layout_height="wrap_content"
+                    android:layout_marginTop="20dp"
+                    android:fontFamily="monospace"
+                    android:text="@{ viewModel.result }"
+                    android:visibility="@{ viewModel.result != null ? View.VISIBLE : View.GONE }" />
+
+            </LinearLayout>
+
+        </ScrollView>
+
+    </androidx.constraintlayout.widget.ConstraintLayout>
+
+</layout>
diff --git a/example/src/main/res/menu/navigation_menu.xml b/example/src/main/res/menu/navigation_menu.xml
index 757f0f54..d60861cd 100644
--- a/example/src/main/res/menu/navigation_menu.xml
+++ b/example/src/main/res/menu/navigation_menu.xml
@@ -27,5 +27,9 @@
         <item
             android:id="@+id/nav_raw_proxy_response"
             android:title="@string/title_raw_proxy_response" />
+
+        <item
+            android:id="@+id/nav_dual_write"
+            android:title="@string/title_dual_write" />
     </group>
 </menu>
\ No newline at end of file
diff --git a/example/src/main/res/navigation/mobile_navigation.xml b/example/src/main/res/navigation/mobile_navigation.xml
index 9b7af348..bac19ae7 100644
--- a/example/src/main/res/navigation/mobile_navigation.xml
+++ b/example/src/main/res/navigation/mobile_navigation.xml
@@ -47,4 +47,10 @@
         android:label="@string/title_raw_proxy_response"
         tools:layout="@layout/fragment_raw_proxy_response" />
 
+    <fragment
+        android:id="@+id/nav_dual_write"
+        android:name="com.basistheory.android.example.view.dual_write.DualWriteFragment"
+        android:label="@string/title_dual_write"
+        tools:layout="@layout/fragment_dual_write" />
+
 </navigation>
\ No newline at end of file
diff --git a/example/src/main/res/values/strings.xml b/example/src/main/res/values/strings.xml
index 8ccc9b75..b9536508 100644
--- a/example/src/main/res/values/strings.xml
+++ b/example/src/main/res/values/strings.xml
@@ -8,6 +8,7 @@
     <string name="title_reveal">Reveal Data</string>
     <string name="title_styling">Custom Styling</string>
     <string name="title_raw_proxy_response">Raw Proxy Response</string>
+    <string name="title_dual_write">HTTP client</string>
 
     <string name="autofill">Autofill</string>
     <string name="tokenize">Tokenize</string>
@@ -31,4 +32,12 @@
     <string name="password">Password</string>
     <string name="phone_number">Phone Number</string>
     <string name="pin">PIN</string>
+
+
+
+    <string name="post">POST</string>
+    <string name="get">GET</string>
+    <string name="delete">DELETE</string>
+    <string name="patch">PATCH</string>
+    <string name="put">PUT</string>
 </resources>
\ No newline at end of file
diff --git a/lib/build.gradle b/lib/build.gradle
index cb0380ea..e0659ca0 100644
--- a/lib/build.gradle
+++ b/lib/build.gradle
@@ -80,6 +80,7 @@ dependencies {
     testImplementation 'io.strikt:strikt-core:0.34.1'
     testImplementation 'com.github.javafaker:javafaker:1.0.2'
     testImplementation 'io.mockk:mockk:1.13.5'
+    testImplementation("com.squareup.okhttp3:mockwebserver:4.11.0")
 }
 
 configurations.all {
diff --git a/lib/src/main/java/com/basistheory/android/service/BasisTheoryElements.kt b/lib/src/main/java/com/basistheory/android/service/BasisTheoryElements.kt
index 176c99d0..c86a1a04 100644
--- a/lib/src/main/java/com/basistheory/android/service/BasisTheoryElements.kt
+++ b/lib/src/main/java/com/basistheory/android/service/BasisTheoryElements.kt
@@ -1,13 +1,13 @@
 package com.basistheory.android.service
 
+import HttpClient
 import com.basistheory.CreateSessionResponse
 import com.basistheory.CreateTokenRequest
 import com.basistheory.CreateTokenResponse
 import com.basistheory.Token
 import com.basistheory.android.model.ElementValueReference
-import com.basistheory.android.util.isPrimitiveType
-import com.basistheory.android.util.toMap
-import com.basistheory.android.util.transformResponseToValueReferences
+import com.basistheory.android.util.*
+import com.basistheory.android.util.getElementsValues
 import com.basistheory.android.util.replaceElementRefs
 import com.basistheory.android.util.tryGetTextToTokenize
 import com.basistheory.android.view.TextElement
@@ -20,16 +20,13 @@ class BasisTheoryElements internal constructor(
     private val dispatcher: CoroutineDispatcher = Dispatchers.IO
 ) {
     val proxy: ProxyApi = apiClientProvider.getProxyApi(dispatcher)
+    val client = HttpClient(dispatcher)
 
     @JvmOverloads
     suspend fun tokenize(body: Any, apiKeyOverride: String? = null): Any =
         withContext(dispatcher) {
             val tokenizeApiClient = apiClientProvider.getTokenizeApi(apiKeyOverride)
-            val request =
-                if (body::class.java.isPrimitiveType()) body
-                else if (body is TextElement) body.getTransformedText()
-                else if (body is ElementValueReference) body.getValue()
-                else replaceElementRefs(body)
+            val request = getElementsValues(body)
 
             tokenizeApiClient.tokenize(request)
         }
diff --git a/lib/src/main/java/com/basistheory/android/service/HttpClient.kt b/lib/src/main/java/com/basistheory/android/service/HttpClient.kt
new file mode 100644
index 00000000..800769d2
--- /dev/null
+++ b/lib/src/main/java/com/basistheory/android/service/HttpClient.kt
@@ -0,0 +1,87 @@
+import com.basistheory.android.service.HttpMethod
+import com.basistheory.android.util.*
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
+import okhttp3.*
+import java.io.IOException
+
+interface Client {
+    suspend fun get(url: String, headers: Map<String, String>? = emptyMap()): Any?
+    suspend fun post(url: String, body: Any?, headers: Map<String, String>? = emptyMap()): Any?
+    suspend fun put(url: String, body: Any?, headers: Map<String, String>? = emptyMap()): Any?
+    suspend fun patch(url: String, body: Any?, headers: Map<String, String>? = emptyMap()): Any?
+    suspend fun delete(url: String, headers: Map<String, String>? = emptyMap()): Any?
+}
+
+class HttpClient(private val dispatcher: CoroutineDispatcher = Dispatchers.IO) : Client {
+    private val client: OkHttpClient = OkHttpClient()
+
+    override suspend fun post(url: String, body: Any?, headers: Map<String, String>?): Any =
+        withContext(dispatcher) {
+            send(url, HttpMethod.POST, body, headers)
+        }
+
+    override suspend fun get(url: String, headers: Map<String, String>?): Any? =
+        withContext(dispatcher) {
+            send(url, HttpMethod.GET, null, headers)
+        }
+
+    override suspend fun put(url: String, body: Any?, headers: Map<String, String>?): Any? =
+        withContext(dispatcher) {
+            send(url, HttpMethod.PUT, body, headers)
+        }
+
+    override suspend fun patch(url: String, body: Any?, headers: Map<String, String>?): Any? =
+        withContext(dispatcher) {
+            send(url, HttpMethod.PATCH, body, headers)
+        }
+
+    override suspend fun delete(url: String, headers: Map<String, String>?): Any? =
+        withContext(dispatcher) {
+            send(url, HttpMethod.DELETE, null, headers)
+        }
+
+    private fun buildRequest(
+        url: String,
+        method: HttpMethod,
+        body: Any?,
+        headers: Map<String, String>
+    ): Request {
+        val contentType = headers["Content-Type"] ?: "application/json"
+
+        val requestBody = body?.let { getElementsValues(it) }?.let {
+            mapObjToRequestBody(contentType, it)
+        }
+
+        val req = Request.Builder()
+            .url(url)
+            .method(
+                method.toString(),
+                requestBody
+            )
+
+        for ((key, value) in headers.entries) {
+            req.addHeader(key, value)
+        }
+
+        return req.build()
+    }
+
+    private suspend fun send(
+        url: String,
+        method: HttpMethod,
+        body: Any?,
+        headers: Map<String, String>?
+    ): String = withContext(dispatcher) {
+        val req = buildRequest(url, method, body, headers ?: emptyMap())
+        val call = client.newCall(req)
+        val response = call.execute()
+
+        if (response.isSuccessful) {
+            response.body?.string() ?: ""
+        } else {
+            throw IOException("$method request failed with response code: ${response.code}")
+        }
+    }
+}
diff --git a/lib/src/main/java/com/basistheory/android/util/DataManipulationUtils.kt b/lib/src/main/java/com/basistheory/android/util/DataManipulationUtils.kt
index 8cb075bb..2a35b5d9 100644
--- a/lib/src/main/java/com/basistheory/android/util/DataManipulationUtils.kt
+++ b/lib/src/main/java/com/basistheory/android/util/DataManipulationUtils.kt
@@ -3,6 +3,10 @@ package com.basistheory.android.util
 import com.basistheory.android.model.ElementValueReference
 import com.basistheory.android.model.exceptions.IncompleteElementException
 import com.basistheory.android.view.TextElement
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.RequestBody
+import okhttp3.RequestBody.Companion.toRequestBody
+import java.io.IOException
 
 fun transformResponseToValueReferences(data: Any?): Any? =
     if (data == null) null
@@ -29,8 +33,7 @@ internal fun replaceElementRefs(value: Any?): Any? {
                 replaceElementRefs(item)
             }
         }
-    }
-    else if (value is Collection<*>) {
+    } else if (value is Collection<*>) {
         value.map {
             it?.let { item ->
                 replaceElementRefs(item)
@@ -38,14 +41,11 @@ internal fun replaceElementRefs(value: Any?): Any? {
         }
     } else {
         when (value) {
-            is TextElement -> {
-                value.tryGetTextToTokenize()
-            }
-            is ElementValueReference -> {
-                value.getValue()
-            }
+            is TextElement -> value.tryGetTextToTokenize()
+            is ElementValueReference -> value.getValue()
             else -> {
-                val children = if (value as? MutableMap<String, Any?> != null) value.toMutableMap() else value.toMap()
+                val children =
+                    if (value as? MutableMap<String, Any?> != null) value.toMutableMap() else value.toMap()
                 for ((key, mapValue) in children) {
                     children[key] = replaceElementRefs(mapValue)
                 }
@@ -64,4 +64,70 @@ internal fun TextElement.tryGetTextToTokenize(): String? {
 }
 
 private fun String.toElementValueReference(): ElementValueReference =
-    ElementValueReference { this }
\ No newline at end of file
+    ElementValueReference { this }
+
+
+internal fun getElementsValues(body: Any) =
+    body.let {
+        when {
+            it::class.java.isPrimitiveType() -> it.toString()
+            it is TextElement -> it.getTransformedText()
+            it is ElementValueReference -> it.getValue()
+            else -> replaceElementRefs(it.toMap())
+        }
+    }
+
+internal fun mapObjToRequestBody(contentType: String, obj: Any): RequestBody? =
+    when (contentType) {
+        "application/json" -> obj.toString().toRequestBody(contentType.toMediaType())
+        "application/x-www-form-urlencoded" -> obj.let {
+            convertObjectToFormUrlEncoded(it)
+        }.let { encodeParamsToFormUrlEncoded(it) }.toRequestBody(
+            contentType.toMediaType()
+        )
+        else -> throw IOException("Content-Type not supported")
+    }
+
+internal fun convertObjectToFormUrlEncoded(obj: Any?, prefix: String = ""): Map<String, String> {
+    val formParams = mutableMapOf<String, String>()
+
+    when (obj) {
+        is Map<*, *> -> {
+            for ((key, value) in obj.entries) {
+                formParams.putAll(
+                    convertObjectToFormUrlEncoded(
+                        value,
+                        if (prefix.isNotEmpty()) "$prefix[$key]" else key.toString()
+                    )
+                )
+            }
+        }
+
+        is List<*> -> obj.withIndex().forEach { (index, value) ->
+            formParams.putAll(
+                convertObjectToFormUrlEncoded(
+                    value,
+                    if (prefix.isNotEmpty()) "$prefix[$index]" else index.toString()
+                )
+            )
+        }
+
+        else -> formParams[(if (prefix.isNotEmpty()) prefix else "")] = obj.toString()
+    }
+
+    return formParams
+}
+
+internal fun encodeParamsToFormUrlEncoded(formParams: Map<String, String>): String =
+    formParams.entries.joinToString("&") { (key, value) ->
+
+        val encodedKey = java.net.URLEncoder.encode(key, "UTF-8")
+
+        val encodedValue =
+            java.net.URLEncoder.encode(
+                value,
+                "UTF-8"
+            )
+
+        "${encodedKey}=${encodedValue}"
+    }
\ No newline at end of file
diff --git a/lib/src/test/java/com/basistheory/android/service/HTTPClientTests.kt b/lib/src/test/java/com/basistheory/android/service/HTTPClientTests.kt
new file mode 100644
index 00000000..61a954f2
--- /dev/null
+++ b/lib/src/test/java/com/basistheory/android/service/HTTPClientTests.kt
@@ -0,0 +1,199 @@
+import junitparams.JUnitParamsRunner
+import kotlinx.coroutines.Dispatchers
+import okhttp3.mockwebserver.MockResponse
+import okhttp3.mockwebserver.MockWebServer
+import kotlinx.coroutines.runBlocking
+import org.junit.After
+import org.junit.Assert.assertEquals
+import org.junit.Assert.assertThrows
+import org.junit.Before
+import org.junit.Test
+import org.junit.runner.RunWith
+import java.io.IOException
+
+@RunWith(JUnitParamsRunner::class)
+class HttpClientTests {
+    private lateinit var server: MockWebServer
+    private lateinit var client: HttpClient
+
+
+    private val endpoint = "/api"
+
+    @Before
+    fun setUp() {
+        server = MockWebServer()
+        server.start()
+
+        client = HttpClient(Dispatchers.IO)
+    }
+
+    @After
+    fun tearDown() {
+        server.shutdown()
+    }
+
+    @Test
+    fun testGetRequest() = runBlocking {
+        server.enqueue(MockResponse().setBody("Got it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.get(url)
+
+        val request = server.takeRequest()
+        assertEquals("GET", request.method)
+        assertEquals(endpoint, request.path)
+    }
+
+    @Test
+    fun testPostRequest() = runBlocking {
+        val expectedRequestBody = "Request body"
+        server.enqueue(MockResponse().setBody("Posted it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.post(url, expectedRequestBody)
+
+        val request = server.takeRequest()
+        assertEquals("POST", request.method)
+        assertEquals(endpoint, request.path)
+        assertEquals(expectedRequestBody, request.body.readUtf8())
+    }
+
+    @Test
+    fun testPutRequest() = runBlocking {
+        val expectedRequestBody = "Request body"
+        server.enqueue(MockResponse().setBody("Put it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.put(url, expectedRequestBody)
+
+        val request = server.takeRequest()
+        assertEquals("PUT", request.method)
+        assertEquals(endpoint, request.path)
+        assertEquals(expectedRequestBody, request.body.readUtf8())
+    }
+
+    @Test
+    fun testPatchRequest() = runBlocking {
+        val expectedRequestBody = "Request body"
+        server.enqueue(MockResponse().setBody("Patched it"))
+
+        val url = server.url(endpoint).toString()
+        client.patch(url, expectedRequestBody)
+
+        val request = server.takeRequest()
+        assertEquals("PATCH", request.method)
+        assertEquals(endpoint, request.path)
+        assertEquals(expectedRequestBody, request.body.readUtf8())
+    }
+
+    @Test
+    fun testDeleteRequest() = runBlocking {
+        server.enqueue(MockResponse().setBody("Deleted it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.delete(url)
+
+        val request = server.takeRequest()
+
+        assertEquals("DELETE", request.method)
+        assertEquals(endpoint, request.path)
+    }
+
+
+    @Test
+    fun testFormUrlEncodedPostRequest() = runBlocking {
+        val expectedRequestBody = object {
+            val type = "card"
+            val billing_details = object {
+                val name = "Peter Panda"
+            }
+            val card = object {
+                val number = "1234567890"
+                val exp_month = 12
+                val exp_year = 2023
+                val cvc = 123
+            }
+        }
+
+        server.enqueue(MockResponse().setBody("Encoded it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.post(
+            url,
+            expectedRequestBody,
+            headers = mapOf("Content-Type" to "application/x-www-form-urlencoded")
+        )
+
+        val request = server.takeRequest()
+        assertEquals("POST", request.method)
+        assertEquals(endpoint, request.path)
+        assertEquals(
+            "type=card&billing_details%5Bname%5D=Peter+Panda&card%5Bnumber%5D=1234567890&card%5Bexp_month%5D=12&card%5Bexp_year%5D=2023&card%5Bcvc%5D=123",
+            request.body.readUtf8()
+        )
+    }
+
+    @Test
+    fun testDefaultsContentTypeToApplicationJsonWhenNoContentTypeIsProvided() = runBlocking {
+        val reqBody = object {
+            val foo = "bar"
+        }
+
+        server.enqueue(MockResponse().setBody("Defaulted it"))
+
+        val url = server.url(endpoint).toString()
+
+        client.post(
+            url,
+            reqBody,
+        )
+
+        val request = server.takeRequest()
+
+        assert(request.headers["Content-Type"]!!.contains("application/json"))
+    }
+
+
+    @Test
+    fun `testHandlesUnsuccessfulResponsesFromTheRemote`() = runBlocking {
+        val reqBody = object {
+            val foo = "bar"
+        }
+
+        server.enqueue(MockResponse().setBody("Everything is broken").setResponseCode(500))
+
+        val url = server.url(endpoint).toString()
+
+        val exception = assertThrows(IOException::class.java) {
+           runBlocking {
+               client.post(url, reqBody) as IOException
+           }
+        }
+
+        assertEquals("POST request failed with response code: 500", exception.message)
+    }
+
+    @Test
+    fun `testThrowsWhenContentTypeIsNotSupported`() = runBlocking {
+        val reqBody = object {
+            val foo = "bar"
+        }
+
+        server.enqueue(MockResponse().setBody("Everything is broken").setResponseCode(200))
+
+        val url = server.url(endpoint).toString()
+
+        val exception = assertThrows(IOException::class.java) {
+            runBlocking {
+                client.post(url, reqBody, mapOf("Content-Type" to "text/plain"))
+            }
+        }
+
+        assertEquals("Content-Type not supported", exception.message)
+    }
+}
diff --git a/lib/src/test/java/com/basistheory/android/util/DualWriteUtilsTests.kt b/lib/src/test/java/com/basistheory/android/util/DualWriteUtilsTests.kt
new file mode 100644
index 00000000..9f66758a
--- /dev/null
+++ b/lib/src/test/java/com/basistheory/android/util/DualWriteUtilsTests.kt
@@ -0,0 +1,97 @@
+import com.basistheory.android.util.mapObjToRequestBody
+import com.basistheory.android.util.convertObjectToFormUrlEncoded
+import com.basistheory.android.util.encodeParamsToFormUrlEncoded
+import com.github.javafaker.Faker
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.RequestBody
+import okhttp3.RequestBody.Companion.toRequestBody
+import org.junit.Assert.assertEquals
+import org.junit.Assert.assertTrue
+import org.junit.Test
+import java.io.IOException
+
+class DualWriteUtilsTests {
+    @Test
+    fun testMapBodyToContentType_Json() {
+        val contentType = "application/json"
+        val obj = object {
+            val name = "John"
+            val age = 30
+        }
+        val expectedRequestBody = obj.toString().toRequestBody(contentType.toMediaType())
+
+        val requestBody = mapObjToRequestBody(contentType, obj)
+
+        assertTrue(requestBody is RequestBody)
+        // RequestBody appends the charset by default
+        assertEquals(expectedRequestBody.contentType(), "$contentType; charset=utf-8".toMediaType())
+        assertEquals(expectedRequestBody.contentLength(), requestBody?.contentLength())
+    }
+
+    @Test
+    fun testMapBodyToContentType_FormUrlEncoded() {
+        val contentType = "application/x-www-form-urlencoded"
+        val obj = object {
+            val name = "John"
+            val age = 30
+        }
+        val expectedRequestBody = encodeParamsToFormUrlEncoded(convertObjectToFormUrlEncoded(obj))
+            .toRequestBody(contentType.toMediaType())
+
+        val requestBody = mapObjToRequestBody(contentType, obj)
+
+        assertTrue(requestBody is RequestBody)
+        assertEquals(expectedRequestBody.contentType(), "$contentType; charset=utf-8".toMediaType())
+        assertEquals(expectedRequestBody.contentLength(), requestBody?.contentLength())
+    }
+
+    @Test(expected = IOException::class)
+    fun testMapBodyToContentType_UnsupportedContentType() {
+        val contentType = "text/plain"
+        val obj = "Sample text"
+
+        mapObjToRequestBody(contentType, obj)
+    }
+
+    @Test
+    fun testConvertObjectToFormUrlEncoded() {
+        val obj = mapOf(
+            "name" to "John",
+            "age" to 30,
+            "address" to mapOf("city" to "New York", "country" to "USA"),
+            "hobbies" to listOf("reading", "painting")
+        )
+
+        val expectedFormParams = mapOf(
+            "name" to "John",
+            "age" to "30",
+            "address[city]" to "New York",
+            "address[country]" to "USA",
+            "hobbies[0]" to "reading",
+            "hobbies[1]" to "painting"
+        )
+
+        val formParams = convertObjectToFormUrlEncoded(obj)
+
+        assertEquals(expectedFormParams, formParams)
+    }
+
+    @Test
+    fun testEncodeParamsToFormUrlEncoded() {
+        val formParams = mapOf(
+            "name" to "John",
+            "age" to "30",
+            "address[city]" to "New York",
+            "address[country]" to "USA",
+            "hobbies[0]" to "reading",
+            "hobbies[1]" to "painting"
+        )
+
+        val expectedEncodedString =
+            "name=John&age=30&address%5Bcity%5D=New+York&address%5Bcountry%5D=USA&hobbies%5B0%5D=reading&hobbies%5B1%5D=painting"
+
+        val encodedString = encodeParamsToFormUrlEncoded(formParams)
+
+        assertEquals(expectedEncodedString, encodedString)
+    }
+}