Compare commits

...

1 Commits

2 changed files with 2 additions and 2 deletions

View File

@@ -223,7 +223,7 @@ func (p *P) Deliver(ev *event.E) {
// Use a separate context with timeout for writes to prevent race conditions
// where the publisher context gets cancelled while writing events
writeCtx, cancel := context.WithTimeout(
context.Background(), WriteTimeout,
context.Background(), DefaultWriteTimeout,
)
defer cancel()

View File

@@ -1 +1 @@
v0.4.1
v0.4.2