mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
Remove todo
This commit is contained in:
@@ -313,10 +313,6 @@ func (c *client) deliverMsg(sub *subscription, mh, msg []byte) {
|
||||
c.pcd[sub.client] = needFlush
|
||||
}
|
||||
|
||||
// TODO
|
||||
// Block pub goroutine on bufio locked write buffer with
|
||||
// go flusher routine. Single for all connections?
|
||||
|
||||
func (c *client) processMsg(msg []byte) {
|
||||
c.nm++
|
||||
if trace {
|
||||
|
||||
Reference in New Issue
Block a user