We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ac1270f commit 5248ec1Copy full SHA for 5248ec1
mono/initiate.go
@@ -61,6 +61,7 @@ func NewProcessor(sc scheduler.Scheduler, hook ProcessorFinallyHook) (Mono, Sink
61
p := globalProcessorPool.get()
62
p.mu.Lock()
63
p.sc = sc
64
+ p.item = nil
65
p.hookOnFinally = hook
66
p.mu.Unlock()
67
return wrap(p), p, p
0 commit comments