diff --git a/build.gradle b/build.gradle
index f84e871..36a7627 100644
--- a/build.gradle
+++ b/build.gradle
@@ -14,6 +14,8 @@ repositories {
 dependencies {
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk8"
     implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.0'
+    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-rx2:1.3.0'
+    implementation "io.reactivex.rxjava2:rxjava:2.2.7"
     implementation "io.reactivex.rxjava3:rxjava:3.0.0-RC2"
     testCompile group: 'junit', name: 'junit', version: '4.12'
 }
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
index 290541c..f80ef9c 100644
--- a/gradle/wrapper/gradle-wrapper.properties
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -1,5 +1,6 @@
+#Wed Sep 18 11:29:24 PDT 2019
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.3-all.zip
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-4.10.3-bin.zip
-zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
diff --git a/src/main/kotlin/interop/completable/CompletableInterop.kt b/src/main/kotlin/interop/completable/CompletableInterop.kt
new file mode 100644
index 0000000..01b51f5
--- /dev/null
+++ b/src/main/kotlin/interop/completable/CompletableInterop.kt
@@ -0,0 +1,17 @@
+package interop.completable
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.rx2.rxCompletable
+import kotlin.coroutines.CoroutineContext
+
+class CompletableInterop(
+    override val coroutineContext: CoroutineContext = Dispatchers.Default
+): CoroutineScope {
+    fun doWork() = CoroutineScope(coroutineContext).rxCompletable {
+        delay(1000)
+        println("Hello from the coroutine!")
+    }
+}
+
diff --git a/src/main/kotlin/interop/completable/TestCompletableInterop.kt b/src/main/kotlin/interop/completable/TestCompletableInterop.kt
new file mode 100644
index 0000000..7513982
--- /dev/null
+++ b/src/main/kotlin/interop/completable/TestCompletableInterop.kt
@@ -0,0 +1,9 @@
+package interop.completable
+
+fun main() {
+    println("Creating an instance of CompletableInterop")
+    val completableInterop = CompletableInterop()
+    completableInterop.doWork().subscribe()
+
+    Thread.sleep(2000) // Sleep the main thread to await the completion of the background thread
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/flowable/FlowableInterop.kt b/src/main/kotlin/interop/flowable/FlowableInterop.kt
new file mode 100644
index 0000000..392a328
--- /dev/null
+++ b/src/main/kotlin/interop/flowable/FlowableInterop.kt
@@ -0,0 +1,17 @@
+package interop.flowable
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.rx2.rxFlowable
+import kotlin.coroutines.CoroutineContext
+
+class FlowableInterop(
+    override val coroutineContext: CoroutineContext = Dispatchers.Default
+): CoroutineScope {
+    fun getFlowable() = CoroutineScope(coroutineContext).rxFlowable {
+        (1..10).map {
+            send(it)
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/flowable/TestFlowableInterop.kt b/src/main/kotlin/interop/flowable/TestFlowableInterop.kt
new file mode 100644
index 0000000..affd8a4
--- /dev/null
+++ b/src/main/kotlin/interop/flowable/TestFlowableInterop.kt
@@ -0,0 +1,13 @@
+package interop.flowable
+
+fun main() {
+    println("Creating FlowableInterop")
+    val flowableInterop = FlowableInterop()
+    flowableInterop.getFlowable()
+        .subscribe({
+            println(it)
+            Thread.sleep(1000) // notice that the producing coroutine's backpressure is handled
+        },::println)
+
+    Thread.sleep(11000) // allow background work to occur before main thread exits
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/maybe/MaybeInterop.kt b/src/main/kotlin/interop/maybe/MaybeInterop.kt
new file mode 100644
index 0000000..f7483b0
--- /dev/null
+++ b/src/main/kotlin/interop/maybe/MaybeInterop.kt
@@ -0,0 +1,15 @@
+package interop.maybe
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.rx2.rxMaybe
+import kotlin.coroutines.CoroutineContext
+import kotlin.random.Random
+
+class MaybeInterop(
+    override val coroutineContext: CoroutineContext = Dispatchers.Default
+): CoroutineScope {
+    fun doWorkMaybe() = CoroutineScope(coroutineContext).rxMaybe {
+        return@rxMaybe if (Random.Default.nextBoolean()) "A value from the function" else null
+    }
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/maybe/TestMaybeInterop.kt b/src/main/kotlin/interop/maybe/TestMaybeInterop.kt
new file mode 100644
index 0000000..330f7cc
--- /dev/null
+++ b/src/main/kotlin/interop/maybe/TestMaybeInterop.kt
@@ -0,0 +1,9 @@
+package interop.maybe
+
+fun main() {
+    println("Creating an instance of MaybeInterop")
+    val maybeInterop = MaybeInterop()
+    maybeInterop.doWorkMaybe().subscribe(::println, ::println)
+
+    Thread.sleep(2000) // Sleep the main thread to await the completion of the background thread
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/observable/ObservableInterop.kt b/src/main/kotlin/interop/observable/ObservableInterop.kt
new file mode 100644
index 0000000..7370100
--- /dev/null
+++ b/src/main/kotlin/interop/observable/ObservableInterop.kt
@@ -0,0 +1,18 @@
+package interop.observable
+
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.rx2.rxObservable
+import kotlin.coroutines.CoroutineContext
+
+class ObservableInterop(
+    override val coroutineContext: CoroutineContext = Dispatchers.Default
+): CoroutineScope {
+    fun getStream() = CoroutineScope(coroutineContext).rxObservable {
+        (1..10).map {
+            delay(100)
+            send(it)
+        }
+    }
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/observable/TestObservableInterop.kt b/src/main/kotlin/interop/observable/TestObservableInterop.kt
new file mode 100644
index 0000000..8d0ba12
--- /dev/null
+++ b/src/main/kotlin/interop/observable/TestObservableInterop.kt
@@ -0,0 +1,9 @@
+package interop.observable
+
+fun main() {
+    println("Creating ObservableInterop")
+    val observableInterop = ObservableInterop()
+    observableInterop.getStream().subscribe(::println, ::println)
+
+    Thread.sleep(2000) // Sleep main thread to allow coroutine to complete
+}
\ No newline at end of file
diff --git a/src/main/kotlin/interop/single/SingleInterop.kt b/src/main/kotlin/interop/single/SingleInterop.kt
new file mode 100644
index 0000000..2c78cc4
--- /dev/null
+++ b/src/main/kotlin/interop/single/SingleInterop.kt
@@ -0,0 +1,15 @@
+package interop.single
+
+import kotlinx.coroutines.*
+import kotlinx.coroutines.rx2.rxSingle
+import kotlin.coroutines.CoroutineContext
+
+class SingleInterop(
+    override val coroutineContext: CoroutineContext = Dispatchers.Default
+): CoroutineScope {
+    fun doWork() = CoroutineScope(coroutineContext).rxSingle {
+        delay(1000)
+        return@rxSingle "Hello!"
+    }
+}
+
diff --git a/src/main/kotlin/interop/single/TestSingleInterop.kt b/src/main/kotlin/interop/single/TestSingleInterop.kt
new file mode 100644
index 0000000..dd3b58e
--- /dev/null
+++ b/src/main/kotlin/interop/single/TestSingleInterop.kt
@@ -0,0 +1,9 @@
+package interop.single
+
+fun main() {
+    println("Creating an instance of SingleInterop")
+    val singleInterop = SingleInterop()
+    singleInterop.doWork().subscribe(::println, ::println)
+
+    Thread.sleep(2000) // Sleep the main thread to await the completion of the background thread
+}