Skip to content

Commit 6e168f8

Browse files
committed
custom onConnect
1 parent 2463499 commit 6e168f8

1 file changed

Lines changed: 9 additions & 0 deletions

File tree

src/service.js

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -737,6 +737,15 @@ module.exports = function (mixinOptions) {
737737
this.dataLoaderOptions = new Map();
738738
this.dataLoaderBatchParams = new Map();
739739

740+
// Bind service to onConnect method
741+
if (
742+
mixinOptions.serverOptions.subscriptions &&
743+
_.isFunction(mixinOptions.serverOptions.subscriptions.onConnect)
744+
) {
745+
mixinOptions.serverOptions.subscriptions.onConnect =
746+
mixinOptions.serverOptions.subscriptions.onConnect.bind(this);
747+
}
748+
740749
const route = _.defaultsDeep(mixinOptions.routeOptions, {
741750
aliases: {
742751
async "/"(req, res) {

0 commit comments

Comments
 (0)