socketio
diff --git a/‎packages/socket.io-cluster-engine/lib/cluster.ts‎
Lines changed: 2 additions & 2 deletions b/‎packages/socket.io-cluster-engine/lib/cluster.ts‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎packages/socket.io-cluster-engine/lib/engine.ts‎
Lines changed: 1 addition & 1 deletion b/‎packages/socket.io-cluster-engine/lib/engine.ts‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/socket.io-cluster-engine/lib/index.ts‎
Lines changed: 1 addition & 0 deletions b/‎packages/socket.io-cluster-engine/lib/index.ts‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎packages/socket.io-cluster-engine/lib/redis.ts‎
Lines changed: 6 additions & 2 deletions b/‎packages/socket.io-cluster-engine/lib/redis.ts‎
Lines changed: 6 additions & 2 deletions
@@ -1,6 +1,6 @@
 import cluster from "node:cluster";
 import { type ServerOptions } from "engine.io";
-import { ClusterEngine, type Message } from "./engine";
+import { ClusterEngine, ClusterEngineOptions, type Message } from "./engine";
 import debugModule from "debug";
 
 const debug = debugModule("engine:cluster");
@@ -42,7 +42,7 @@ export function setupPrimary() {
 }
 
 export class NodeClusterEngine extends ClusterEngine {
-  constructor(opts?: ServerOptions) {
+  constructor(opts?: ServerOptions & ClusterEngineOptions) {
     super(opts);
 
     process.on("message", (message: Message & { _source?: string }) => {
 
@@ -141,7 +141,7 @@ function isValidSessionId(str: string) {
   return typeof str === "string" && str.length === 20;
 }
 
-interface ClusterEngineOptions {
+export interface ClusterEngineOptions {
   /**
    * The maximum waiting time for responses from other nodes, in ms.
    *
 
@@ -1,2 +1,3 @@
 export { setupPrimary, NodeClusterEngine } from "./cluster";
 export { setupPrimaryWithRedis, RedisEngine } from "./redis";
+export { type ClusterEngineOptions } from "./engine";
@@ -1,4 +1,4 @@
-import { ClusterEngine, type Message } from "./engine";
+import { ClusterEngine, ClusterEngineOptions, type Message } from "./engine";
 import { encode, decode } from "@msgpack/msgpack";
 import { type ServerOptions } from "engine.io";
 import cluster from "node:cluster";
@@ -134,7 +134,11 @@ export class RedisEngine extends ClusterEngine {
   private readonly _pubClient: any;
   private readonly _channelPrefix: string;
 
-  constructor(pubClient: any, subClient: any, opts?: RedisEngineOptions) {
+  constructor(
+    pubClient: any,
+    subClient: any,
+    opts?: RedisEngineOptions & ClusterEngineOptions,
+  ) {
     super(opts);
     this._pubClient = pubClient;
     this._channelPrefix = opts?.channelPrefix || "engine.io";
Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,7 @@ function isValidSessionId(str: string) {`
`141`	`141`	`return typeof str === "string" && str.length === 20;`
`142`	`142`	`}`
`143`	`143`
`144`		`-interface ClusterEngineOptions {`
	`144`	`+export interface ClusterEngineOptions {`
`145`	`145`	`/**`
`146`	`146`	`* The maximum waiting time for responses from other nodes, in ms.`
`147`	`147`	`*`
Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,3 @@`
`1`	`1`	`export { setupPrimary, NodeClusterEngine } from "./cluster";`
`2`	`2`	`export { setupPrimaryWithRedis, RedisEngine } from "./redis";`
	`3`	`+export { type ClusterEngineOptions } from "./engine";`