[plc4x] 02/04: feat(plc4go/spi): added new ConnectWithContext to message codec

[sr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git

commit 1f38cc9f8d0eccbd9f7dcebbcd19f1c300f1b641
Author: Sebastian Rühl <sr...@apache.org>
AuthorDate: Wed Aug 17 13:22:22 2022 +0200

    feat(plc4go/spi): added new ConnectWithContext to message codec
---
 plc4go/spi/MessageCodec.go         | 2 ++
 plc4go/spi/default/DefaultCodec.go | 6 +++++-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/plc4go/spi/MessageCodec.go b/plc4go/spi/MessageCodec.go
index 8507dae74..2e373ed4a 100644
--- a/plc4go/spi/MessageCodec.go
+++ b/plc4go/spi/MessageCodec.go
@@ -46,6 +46,8 @@ type HandleError func(err error) error
 type MessageCodec interface {
 	// Connect connects this codec
 	Connect() error
+	// ConnectWithContext connects this codec with the supplied context
+	ConnectWithContext(ctx context.Context) error
 	// Disconnect disconnects this codec
 	Disconnect() error
 	// IsRunning returns tur if the codec (workers are running)
diff --git a/plc4go/spi/default/DefaultCodec.go b/plc4go/spi/default/DefaultCodec.go
index 6fee263e8..25937d8a5 100644
--- a/plc4go/spi/default/DefaultCodec.go
+++ b/plc4go/spi/default/DefaultCodec.go
@@ -146,9 +146,13 @@ func (m *defaultCodec) GetDefaultIncomingMessageChannel() chan spi.Message {
 }
 
 func (m *defaultCodec) Connect() error {
+	return m.ConnectWithContext(context.Background())
+}
+
+func (m *defaultCodec) ConnectWithContext(ctx context.Context) error {
 	log.Trace().Msg("Connecting")
 	if !m.transportInstance.IsConnected() {
-		if err := m.transportInstance.Connect(); err != nil {
+		if err := m.transportInstance.ConnectWithContext(ctx); err != nil {
 			return err
 		}
 	} else {