fix(flow): emit partial sliding window on early close (#192)

reugn · web-flow · commit 18f3717f85d7 · 2025-11-15T22:50:28.000+02:00
diff --git a/flow/sliding_window.go b/flow/sliding_window.go
@@ -223,6 +223,9 @@ func (sw *SlidingWindow[T]) emit(delta time.Duration) {
 	case <-timer.C:
 	case <-sw.done:
 		timer.Stop()
+		if sw.opts.EmitPartialWindow {
+			sw.dispatchWindow()
+		}
 		return
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -223,6 +223,9 @@ func (sw *SlidingWindow[T]) emit(delta time.Duration) {`
`223`	`223`	`case <-timer.C:`
`224`	`224`	`case <-sw.done:`
`225`	`225`	`timer.Stop()`
	`226`	`+ if sw.opts.EmitPartialWindow {`
	`227`	`+ sw.dispatchWindow()`
	`228`	`+ }`
`226`	`229`	`return`
`227`	`230`	`}`
`228`	`231`