x
This commit is contained in:
+2
-2
@@ -111,13 +111,13 @@ func handleWebsocket(c *gin.Context) {
|
|||||||
res.conn = wc
|
res.conn = wc
|
||||||
req._event = "connect"
|
req._event = "connect"
|
||||||
wc.conn = ws
|
wc.conn = ws
|
||||||
function.Handle(&Faker{
|
go function.Handle(&Faker{
|
||||||
Type: "websocket",
|
Type: "websocket",
|
||||||
}, func(vm *goja.Runtime) {
|
}, func(vm *goja.Runtime) {
|
||||||
vm.Set("res", res)
|
vm.Set("res", res)
|
||||||
vm.Set("req", req)
|
vm.Set("req", req)
|
||||||
})
|
})
|
||||||
// message
|
time.Sleep(time.Millisecond*500)
|
||||||
for {
|
for {
|
||||||
_, data, err := ws.ReadMessage()
|
_, data, err := ws.ReadMessage()
|
||||||
wc.patterns.Range(func(key, value any) bool {
|
wc.patterns.Range(func(key, value any) bool {
|
||||||
|
|||||||
Reference in New Issue
Block a user