ModbusTCPAssembler is now public

aldas · Jul 27, 2023 · 5d13400 · 5d13400
1 parent 8d278e4
commit 5d13400
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/server/modbus.go b/server/modbus.go
@@ -9,7 +9,7 @@ import (
 
 // ModbusTCPAssembler assembles read data into complete packets and calls ModbusHandler with assembled packet
 type ModbusTCPAssembler struct {
- handler ModbusHandler
+ Handler ModbusHandler
  received bytes.Buffer
 }
 
@@ -29,7 +29,7 @@ func (m *ModbusTCPAssembler) ReceiveRead(ctx context.Context, received []byte, b
  return err.(*packet.ErrorParseTCP).Bytes(), false
  }
 
- resp, err := m.handler.Handle(ctx, p)
+ resp, err := m.Handler.Handle(ctx, p)
  if err != nil {
  var target *packet.ErrorParseTCP
  if errors.As(err, &target) {

diff --git a/server/server.go b/server/server.go
@@ -112,7 +112,7 @@ type ContextRemoteAddr struct{}
 func (s *Server) serve(ctx context.Context, listener net.Listener, handler ModbusHandler) error {
  if s.AssemblerCreatorFunc == nil {
  s.AssemblerCreatorFunc = func(handler ModbusHandler) PacketAssembler {
- return &ModbusTCPAssembler{handler: handler}
+ return &ModbusTCPAssembler{Handler: handler}
  }
  }
  onErrorFunc := s.OnErrorFunc