Skip to content

M
mybee
Commit 496b2320 authored by Michelle Plur's avatar Michelle Plur Committed by GitHub
Browse files
Options

Update hive.go (#1170)

parent fb6688ef
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
pkg/hive/hive.go
View file @ 496b2320
...@@ -125,7 +125,7 @@ func (s *Service) peersHandler(ctx context.Context, peer p2p.Peer, stream p2p.St ...@@ -125,7 +125,7 @@ func (s *Service) peersHandler(ctx context.Context, peer p2p.Peer, stream p2p.St
} }
// close the stream before processing in order to unblock the sending side // close the stream before processing in order to unblock the sending side
// fullclose is called async because there is no need to wait for conformation, // fullclose is called async because there is no need to wait for confirmation,
// but we still want to handle not closed stream from the other side to avoid zombie stream // but we still want to handle not closed stream from the other side to avoid zombie stream
go stream.FullClose() go stream.FullClose()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment