add test for queued response (#217)

@@ -22,6 +22,8 @@ import org.mockito.Mock
 import org.mockito.Mockito
 import org.mockito.Mockito
 import org.mockito.kotlin.any
 import org.mockito.kotlin.any
 import org.mockito.kotlin.argThat
 import org.mockito.kotlin.argThat
+import org.mockito.kotlin.inOrder
+import org.mockito.kotlin.times
 import org.webrtc.SessionDescription
 import org.webrtc.SessionDescription
 
 
 @ExperimentalCoroutinesApi
 @ExperimentalCoroutinesApi
@@ -157,6 +159,29 @@ class SignalClientTest : BaseTest() {
             .onClose(any(), any())
             .onClose(any(), any())
     }
     }
 
 
+    /**
+     * Ensure responses that come in before [SignalClient.onReadyForResponses] are queued.
+     */
+    @Test
+    fun queuedResponses() = runTest {
+
+        val inOrder = inOrder(listener)
+        val job = async {
+            client.join(EXAMPLE_URL, "")
+        }
+        connectWebsocketAndJoin()
+        job.await()
+
+        client.onMessage(wsFactory.ws, OFFER.toOkioByteString())
+        client.onMessage(wsFactory.ws, ROOM_UPDATE.toOkioByteString())
+        client.onMessage(wsFactory.ws, ROOM_UPDATE.toOkioByteString())
+
+        client.onReadyForResponses()
+
+        inOrder.verify(listener).onOffer(any())
+        inOrder.verify(listener, times(2)).onRoomUpdate(any())
+    }
+
     @Test
     @Test
     fun sendRequest() = runTest {
     fun sendRequest() = runTest {
         val job = async { client.join(EXAMPLE_URL, "") }
         val job = async { client.join(EXAMPLE_URL, "") }