Create waiters map

This commit is contained in:
mcrakhman 2022-10-19 22:57:34 +02:00
parent 64e0ba3b77
commit efa3acc368
No known key found for this signature in database
GPG Key ID: DED12CFEF5B8396B

View File

@ -55,6 +55,7 @@ func newStreamPool(messageHandler MessageHandler) StreamPool {
s := &streamPool{
peerStreams: make(map[string]spacesyncproto.SpaceStream),
messageHandler: messageHandler,
waiters: make(map[string]responseWaiter),
wg: &sync.WaitGroup{},
}
s.lastUsage.Store(time.Now().Unix())