Create waiters map

This commit is contained in:
mcrakhman 2022-10-19 22:57:34 +02:00 committed by Mikhail Iudin
parent bb156e1bd0
commit df4f1d709d
No known key found for this signature in database
GPG Key ID: FAAAA8BAABDFF1C0

View File

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