From 5cf44eda3e85a0dc2e84cd530a310aac281fd986 Mon Sep 17 00:00:00 2001
From: Termina1 <terminal2010@gmail.com>
Date: Fri, 27 Dec 2024 12:32:44 +0200
Subject: [PATCH] broadcast diffs and handshakes

---
 sync.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sync.go b/sync.go
index d08f589..1e1169e 100644
--- a/sync.go
+++ b/sync.go
@@ -629,13 +629,13 @@ func (sync *Syncer) Drain(ctx context.Context, recs protocol.Records) (err error
 		fallthrough
 
 	case SendDiff:
-		broadcast := false
+		broadcast := true
 		lit := LastLit(recs)
 		if lit != 'D' && lit != 'V' {
 			if lit == 'B' {
+				broadcast = false
 				sync.SetDrainState(ctx, SendNone)
 			} else {
-				broadcast = true
 				sync.SetDrainState(ctx, SendLive)
 			}
 		}