1 files changed, 12 insertions, 2 deletions
diff --git a/reactive/kotlinx-coroutines-reactive/test/PublisherAsFlowTest.kt b/reactive/kotlinx-coroutines-reactive/test/PublisherAsFlowTest.kt
index 04833e98..7a0e0fac 100644
--- a/reactive/kotlinx-coroutines-reactive/test/PublisherAsFlowTest.kt
+++ b/reactive/kotlinx-coroutines-reactive/test/PublisherAsFlowTest.kt
@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package kotlinx.coroutines.reactive
@@ -71,7 +71,7 @@ class PublisherAsFlowTest : TestBase() {
                 send(it + 1)
                 expect(it + 1)
             }
-            assertFalse { offer(-1) }
+            assertFalse { trySend(-1).isSuccess }
         }
 
         publisher.asFlow().collect {
@@ -263,4 +263,14 @@ class PublisherAsFlowTest : TestBase() {
         }
         assertEquals(expected, list)
     }
+
+    @Test
+    fun testException() = runTest {
+        expect(1)
+        val p = publish<Int> { throw TestException() }.asFlow()
+        p.catch {
+            assertTrue { it is TestException }
+            finish(2)
+        }.collect()
+    }
 }