fix once() method

shw0471 · Mar 29, 2022 · d086e9d · d086e9d
1 parent 13fb611
commit d086e9d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cocket/src/main/java/com/semicolon/cocket/CocketExecutor.kt b/cocket/src/main/java/com/semicolon/cocket/CocketExecutor.kt
@@ -122,10 +122,10 @@ class CocketExecutor(
 
     private fun once(method: Method): Any {
         require(method.returnType == Flow::class.java) { "@ReceiveOnce method should return coroutine Flow." }
-        val event = (method.annotations[0] as On).value
+        val event = (method.annotations[0] as Once).value
         val genericType = (method.genericReturnType as ParameterizedType).actualTypeArguments[0]
         return callbackFlow<Any> {
-            socketClient.on(event) {
+            socketClient.once(event) {
                 if (genericType != Unit.javaClass)
                     trySend(gson.fromJson(it[0].toString(), genericType))
                 else trySend(Unit)