OptionReadQLen is used to set the size, in messages, of the read queue channel. By default, it's 128. This option cannot be set if Dial or Listen has been called on the socket.
sock.uwq = make(chan *Message, sock.uwqLen) return nil case OptionReadQLen: sock.Lock() defer sock.Unlock()
defer sock.Unlock() return sock.uwqLen, nil case OptionReadQLen: sock.Lock() defer sock.Unlock()
OptionReadQLen is referenced in 2 repositoriesgithub.com/go-mangos/mangos
- 2 references in core.go
OptionReadQLen = "READQ-LEN"