Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
b61bf52df9 | |||
f1dd467c95 |
@ -178,6 +178,6 @@ var results = store.query(ctx, "myCollection", {
|
|||||||
limit: 10,
|
limit: 10,
|
||||||
offset: 5,
|
offset: 5,
|
||||||
orderBy: "foo",
|
orderBy: "foo",
|
||||||
orderDirection: store.ASC,
|
orderDirection: store.DIRECTION_ASC,
|
||||||
});
|
});
|
||||||
```
|
```
|
||||||
|
@ -38,9 +38,10 @@ func (m *Module) broadcast(call goja.FunctionCall, rt *goja.Runtime) goja.Value
|
|||||||
}
|
}
|
||||||
|
|
||||||
data := call.Argument(0).Export()
|
data := call.Argument(0).Export()
|
||||||
|
ctx := context.Background()
|
||||||
|
|
||||||
msg := module.NewServerMessage(nil, data)
|
msg := module.NewServerMessage(ctx, data)
|
||||||
if err := m.bus.Publish(context.Background(), msg); err != nil {
|
if err := m.bus.Publish(ctx, msg); err != nil {
|
||||||
panic(rt.ToValue(errors.WithStack(err)))
|
panic(rt.ToValue(errors.WithStack(err)))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user