diff --git a/src/server/api/streaming.ts b/src/server/api/streaming.ts
index aed0e674f..c8c4a8a29 100644
--- a/src/server/api/streaming.ts
+++ b/src/server/api/streaming.ts
@@ -31,7 +31,7 @@ module.exports = (server: http.Server) => {
 					payload = payload.body;
 				}
 				if (type.startsWith('api:')) {
-					type = payload.type.replace('api:', 'api-res:');
+					type = type.replace('api:', 'api-res:');
 				}
 				connection.send(JSON.stringify({
 					type: type,