refactor(input): drop unused forwarder test hook

commit: 1a34c2a6e696eaae31abe0938cb47aa6504c24ee
author: brice · 28d ago · 2026-09-24 16:12 UTC
committer: brice · 28d ago · 2026-09-24 16:12 UTC
parent: 1bf994b
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email

1 file · +4 -8

M internal/adapters/libinput/forward.go +4 -8


@@ -13,11 +13,10 @@ import (
13	13		// motions still waiting to be sent collapse into the latest one, while keys
14	14		// and buttons keep their order relative to motion.
15	15		type forwarder struct {
16		-	mu sync.Mutex
17		-	queue []ports.InputEvent
18		-	wake chan struct{}
19		-	stats forwardStats
20		-	notify func() // test hook: called after each send
	16	+	mu sync.Mutex
	17	+	queue []ports.InputEvent
	18	+	wake chan struct{}
	19	+	stats forwardStats
21	20		}
22	21
23	22		// forwardStats is reset by take.

@@ -96,8 +95,5 @@ func (f *forwarder) run(ctx context.Context, input chan<- ports.InputEvent) {
96	95		f.stats.Sent++
97	96		f.stats.MaxBlock = max(f.stats.MaxBlock, d)
98	97		f.mu.Unlock()
99		-	if f.notify != nil {
100		-	f.notify()
101		-	}
102	98		}
103	99		}

 // motions still waiting to be sent collapse into the latest one, while keys
 // and buttons keep their order relative to motion.
 type forwarder struct {
-	mu     sync.Mutex
+	mu    sync.Mutex
-	queue  []ports.InputEvent
+	queue []ports.InputEvent
-	wake   chan struct{}
+	wake  chan struct{}
-	stats  forwardStats
+	stats forwardStats
-	notify func() // test hook: called after each send
 }
 // forwardStats is reset by take.
 		f.stats.Sent++
 		f.stats.MaxBlock = max(f.stats.MaxBlock, d)
 		f.mu.Unlock()
-		if f.notify != nil {
-			f.notify()
-		}
 	}
 }