Merge pull request #447 from blinklabs-io/feat/chainsync-server-await…

…reply feat: chain-sync server AwaitReply function
blinklabs-io · Dec 2, 2023 · c1a2c14 · c1a2c14
2 parents 4430d8f + a7c6e10
commit c1a2c14
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/protocol/chainsync/server.go b/protocol/chainsync/server.go
@@ -62,6 +62,11 @@ func (s *Server) RollBackward(point common.Point, tip Tip) error {
 	return s.SendMessage(msg)
 }
 
+func (s *Server) AwaitReply() error {
+	msg := NewMsgAwaitReply()
+	return s.SendMessage(msg)
+}
+
 func (s *Server) RollForward(blockType uint, blockData []byte, tip Tip) error {
 	if s.Mode() == protocol.ProtocolModeNodeToNode {
 		eraId := ledger.BlockToBlockHeaderTypeMap[blockType]