EmitwithAck never listens for the callback from the client so it always timed out

[danielAsaboro]

This is a snippet from my code,
I'm porting a socket service already written in nodejs to go...
and this emitWithAck never returns a response ...it times out.

yet, the client automatically acknowledge the message as soon as it gets it
(it's instantaneous btw)

io.Timeout(180*time.Second).EmitWithAck("this-rider-location", receivedMessage)(
				func(args []any, err error) {
					fmt.Print(err)
					if err == nil {
                                        fmt.Println("we got a response")
                                        }
}
                                        

[danielAsaboro]

It turns out that it works, but i only get the responses from the acknowledgement (args) after timeout.
is there a way to get it as it arrives (asynchronously)? IIRC, the Nodejs socket io library does this.
And is this a skill issue on my end?

I'm doing this because I'm setting up a quiz platform where the message gets pushed to all connected clients...
and i want to use how fast they respond in grading them also

[zishang520]

The broadcast EmitWithAck will wait for all clients to respond or time out before returning data.

[danielAsaboro]

Hi, thanks for the response.
Please is there an available API to broadcast to the room, and get the callback response when each client does response and not together?

[zishang520]

Depending on your needs, you should use Ack for each clinet instead of broadcasting Ack, as in the following example:

io.On("connection", func(clients ...interface{}) {
		client := clients[0].(*socket.Socket)
		client.EmitWithAck("this-rider-location", "receivedMessage")(
			func(args []any, err error) {
				fmt.Print(err)
				if err == nil {
					fmt.Println("we got a response")
				}
			})
		client.On("disconnect", func(...interface{}) {
			// utils.Log().Success("/ test disconnect")
		})
	})

[danielAsaboro]

Return: a func(func([]any, error)) that will be fulfilled when all clients have acknowledged the event
using client does the same — wait for all client...
my use-case would love to initiate an action as each clients acknowledge not wait for all

I appreciate the help regardless, thank you

[zishang520]

If you have any other questions, please feel free to contact me.