diff --git a/src/WebSocketWrapper.h b/src/WebSocketWrapper.h index f1b32216..f872620f 100644 --- a/src/WebSocketWrapper.h +++ b/src/WebSocketWrapper.h @@ -49,7 +49,8 @@ struct WebSocketWrapper { if (topic.isInvalid(args)) { return; } - ws->subscribe(topic.getString()); + bool nonStrict = args.Length() > 1 && BooleanValue(isolate, args[1]); + ws->subscribe(topic.getString(), nonStrict); } } @@ -63,7 +64,8 @@ struct WebSocketWrapper { if (topic.isInvalid(args)) { return; } - bool success = ws->unsubscribe(topic.getString()); + bool nonStrict = args.Length() > 1 && BooleanValue(isolate, args[1]); + bool success = ws->unsubscribe(topic.getString(), nonStrict); args.GetReturnValue().Set(Boolean::New(isolate, success)); } } diff --git a/uWebSockets b/uWebSockets index 359c26b0..a17a6a72 160000 --- a/uWebSockets +++ b/uWebSockets @@ -1 +1 @@ -Subproject commit 359c26b0bf8e728bf857dacacff70627c6ae5738 +Subproject commit a17a6a7268ee6d17c7aec51afa27264c1981aec6