Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
6e06905773
|
@@ -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()
|
||||
|
||||
|
||||
@@ -1 +1 @@
|
||||
v0.4.1
|
||||
v0.4.2
|
||||
Reference in New Issue
Block a user