fix(plc4go/spi): fix concurrency issue in DefaultCodec

apache · Apr 18, 2023 · 0cbf147 · 0cbf147
1 parent 189b0fc
commit 0cbf147
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/plc4go/spi/default/DefaultCodec.go b/plc4go/spi/default/DefaultCodec.go
@@ -209,18 +209,18 @@ func (m *defaultCodec) TimeoutExpectations(now time.Time) {
 			// Remove this expectation from the list.
 			m.expectations = append(m.expectations[:index], m.expectations[index+1:]...)
 			// Call the error handler.
-			go func() {
+			go func(expectation spi.Expectation) {
 				if err := expectation.GetHandleError()(plcerrors.NewTimeoutError(now.Sub(expectation.GetExpiration()))); err != nil {
 					log.Error().Err(err).Msg("Got an error handling error on expectation")
 				}
-			}()
+			}(expectation)
 		}
 		if err := expectation.GetContext().Err(); err != nil {
-			go func() {
+			go func(expectation spi.Expectation) {
 				if err := expectation.GetHandleError()(err); err != nil {
 					log.Error().Err(err).Msg("Got an error handling error on expectation")
 				}
-			}()
+			}(expectation)
 		}
 	}
 }