diff --git a/packages/java/endpoint/src/main/java/dev/hilla/generator/typescript/CodeGenerator.java b/packages/java/endpoint/src/main/java/dev/hilla/generator/typescript/CodeGenerator.java
index 3d134fda27..9180e5a450 100644
--- a/packages/java/endpoint/src/main/java/dev/hilla/generator/typescript/CodeGenerator.java
+++ b/packages/java/endpoint/src/main/java/dev/hilla/generator/typescript/CodeGenerator.java
@@ -318,8 +318,8 @@ public String getTypeDeclaration(Schema schema) {
             Schema inner = arraySchema.getItems();
             if (schema.getExtensions() != null
                     && schema.getExtensions().containsKey("x-flux")) {
-                return String.format("Subscription<%s>%s",
-                        this.getTypeDeclaration(inner), optionalSuffix);
+                return String.format("Subscription<%s>",
+                        this.getTypeDeclaration(inner));
             } else {
                 return String.format("Array<%s>%s",
                         this.getTypeDeclaration(inner), optionalSuffix);
diff --git a/packages/java/endpoint/src/test/resources/dev/hilla/generator/endpoints/flux/expected-FluxTestEndpoint.ts b/packages/java/endpoint/src/test/resources/dev/hilla/generator/endpoints/flux/expected-FluxTestEndpoint.ts
index 18da9d45df..9b54d4c4ba 100644
--- a/packages/java/endpoint/src/test/resources/dev/hilla/generator/endpoints/flux/expected-FluxTestEndpoint.ts
+++ b/packages/java/endpoint/src/test/resources/dev/hilla/generator/endpoints/flux/expected-FluxTestEndpoint.ts
@@ -23,7 +23,7 @@ Subscription<User> {
 * Return a list of users
 */
 function _getAllUsers():
-Subscription<User | undefined> | undefined {
+Subscription<User | undefined> {
   return client.subscribe (
     'FluxTestEndpoint', 'getAllUsers',{}
   );