- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for numblocks (0.17 sec)
-
internal/grid/muxserver.go
if msg.DeadlineMS == 0 || msg.DeadlineMS > uint32(lastPingThreshold/time.Millisecond) { go func() { wg.Wait() m.checkRemoteAlive() }() } return &m } // handleInbound sends unblocks when we have delivered the message to the handler. func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) { for in := range inbound { handlerIn <- in
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0)