Function subscribe

wasm/query.go:87–109

(gj *core.GraphJin)

}

func subscribe(gj *core.GraphJin) js.Func {
	return js.FuncOf(func(this js.Value, args []js.Value) interface{} {
		var qa queryArgs
		if err := processArgs(&qa, args, "query"); !err.IsUndefined() {
			return err
		}

		c := context.TODO()
		if qa.userID != nil {
			c = context.WithValue(c, core.UserIDKey, qa.userID)
		}

		fn := func(resolve, reject js.Value) {
			res, err := gj.Subscribe(c, qa.query, qa.vars, nil)
			if err != nil {
				reject.Invoke(toJSError(err))
			} else {
				resolve.Invoke(fromMember(res))
			}
		}
		return toAwait(fn)
	})
}

func subscribeByName(gj *core.GraphJin) js.Func {
	return js.FuncOf(func(this js.Value, args []js.Value) interface{} {