(plc4x) branch develop updated: fix(plc4go/cbus): device scan mess-up

[sruehl]

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


The following commit(s) were added to refs/heads/develop by this push:
     new 327def0c3d fix(plc4go/cbus): device scan mess-up
327def0c3d is described below

commit 327def0c3db09416d9c4ff93346487be4c156283
Author: Sebastian Rühl <sru...@apache.org>
AuthorDate: Fri Mar 7 10:16:06 2025 +0100

    fix(plc4go/cbus): device scan mess-up
---
 plc4go/internal/cbus/Discoverer.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/plc4go/internal/cbus/Discoverer.go 
b/plc4go/internal/cbus/Discoverer.go
index ca3e72b2c7..d11965df3c 100644
--- a/plc4go/internal/cbus/Discoverer.go
+++ b/plc4go/internal/cbus/Discoverer.go
@@ -203,12 +203,12 @@ func (d *Discoverer) Discover(ctx context.Context, 
callback func(event apiModel.
                                        d.log.Debug().Err(err).Msg("error 
waiting for completion")
                                }
                        }()
-                       deviceScanWg.Wait()
-                       d.log.Info().Msg("Discovery done")
-                       d.transportInstanceCreationQueue.Stop()
-                       d.deviceScanningQueue.Stop()
-                       // TODO: do we maybe want a callback for that? As 
option for example
                }
+               deviceScanWg.Wait()
+               d.log.Info().Msg("Discovery done")
+               d.transportInstanceCreationQueue.Stop()
+               d.deviceScanningQueue.Stop()
+               // TODO: do we maybe want a callback for that? As option for 
example
        }()
        return nil
 }