Promote RpcResponseMessage to an actual class

beemobot · Jan 13, 2024 · 749528c · 749528c
1 parent 0a85119
commit 749528c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/latte/src/main/java/gg/beemo/latte/broker/BrokerMessage.kt b/latte/src/main/java/gg/beemo/latte/broker/BrokerMessage.kt
@@ -25,7 +25,6 @@ open class BrokerMessage<T, H : BrokerMessageHeaders>(
 typealias AbstractBrokerMessage<T> = BrokerMessage<T, out BrokerMessageHeaders>
 typealias BaseBrokerMessage<T> = BrokerMessage<T, BrokerMessageHeaders>
 typealias BaseRpcRequestMessage<RequestT, ResponseT> = RpcRequestMessage<RequestT, ResponseT, BrokerMessageHeaders>
-typealias RpcResponseMessage<T> = BrokerMessage<T, RpcMessageHeaders>
 
 class RpcRequestMessage<RequestT, ResponseT, H : BrokerMessageHeaders>(
     topic: String,
@@ -40,3 +39,11 @@ class RpcRequestMessage<RequestT, ResponseT, H : BrokerMessageHeaders>(
     }
 
 }
+
+class RpcResponseMessage<ResponseT>(topic: String, key: String, value: ResponseT, headers: RpcMessageHeaders) :
+    BrokerMessage<ResponseT, RpcMessageHeaders>(topic, key, value, headers) {
+
+    val status: RpcStatus
+        get() = headers.status
+
+}