Receivers

Aug 2, 2023

Changes in this version

+ var PackageMaxLen = 64 * 1024

+ var PackageMinLen = 1024

Oct 28, 2022

Changes in this version

type DynamicReceiver

+ func (d *DynamicReceiver) Recovery(conn netInterface.IConnection)

+ type SpliceStartAndDataLengthHexReceiver struct

+ func NewSpliceStartAndDataLengthHexReceiver(startSymbol []byte, appendCount int, dataLengthIndex int, dataLengthCount int) *SpliceStartAndDataLengthHexReceiver

+ func (s *SpliceStartAndDataLengthHexReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (s *SpliceStartAndDataLengthHexReceiver) GetHeadLen() int

+ func (s *SpliceStartAndDataLengthHexReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ func (s *SpliceStartAndDataLengthHexReceiver) Reset()

+ type SpliceStartAndDataLengthReceiver struct

+ func NewSpliceStartAndDataLengthReceiver(startSymbol []byte, appendCount int, dataLengthIndex int, dataLengthCount int) *SpliceStartAndDataLengthReceiver

+ func (s *SpliceStartAndDataLengthReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (s *SpliceStartAndDataLengthReceiver) GetHeadLen() int

+ func (s *SpliceStartAndDataLengthReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ func (s *SpliceStartAndDataLengthReceiver) Reset()

+ type SpliceStartAndLengthReceiver struct

+ func NewSpliceStartAndLengthReceiver(symbol byte, length int) *SpliceStartAndLengthReceiver

+ func (s *SpliceStartAndLengthReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (s *SpliceStartAndLengthReceiver) GetHeadLen() int

+ func (s *SpliceStartAndLengthReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ func (s *SpliceStartAndLengthReceiver) Reset()

+ type SpliceStartFinishManyReceiver struct

+ func NewSpliceStartFinishManyReceiver(startSymbol []byte, finishSymbol []byte) *SpliceStartFinishManyReceiver

+ func (s *SpliceStartFinishManyReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (s *SpliceStartFinishManyReceiver) GetHeadLen() int

+ func (s *SpliceStartFinishManyReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ func (s *SpliceStartFinishManyReceiver) Reset()

Feb 9, 2022

Changes in this version

+ type EmptyReceiver struct

+ func (s *EmptyReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (s *EmptyReceiver) GetHeadLen() int

+ func (s *EmptyReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ func (s *EmptyReceiver) Reset()

Dec 16, 2021

Changes in this version

type JT1078Receiver

+ func (j *JT1078Receiver) Reset()

type SpliceSymbolReceiver

+ func (s *SpliceSymbolReceiver) Reset()

Sep 5, 2021

Changes in this version

type DynamicReceiver

+ OnReceive func(data []byte)

Aug 18, 2021

Changes in this version

type DynamicReceiver

+ BytesCache *bytes.Buffer

+ HDataCache bool

Aug 18, 2021

Changes in this version

type JT1078Receiver

+ func (j *JT1078Receiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (j *JT1078Receiver) GetHeadLen() int

type SpliceSymbolReceiver

+ func (S *SpliceSymbolReceiver) GetHeadLen() int

+ func (s *SpliceSymbolReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

Aug 17, 2021

Changes in this version

+ func NewDynamicJT1078Receiver(startBf []byte) netInterface.IReceiver

+ type DynamicJT1078Receiver struct

+ JT1078Receiver *JT1078Receiver

+ func (d *DynamicJT1078Receiver) IsMeHandle(conn netInterface.IConnection, buffer []byte) bool

+ func (d *DynamicJT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

+ type JT1078Receiver struct

+ func NewJT1078Receiver(startBf []byte) *JT1078Receiver

+ func (j *JT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

Jun 8, 2021

Changes in this version

type DynamicReceiver

+ ReceiverLen int

Dec 10, 2020

Changes in this version

+ func NewDynamicSpliceSymbol(startSymbol byte, finishSymbol byte) netConn.IReceiver

+ type DynamicSpliceSymbol struct

+ func (d *DynamicSpliceSymbol) IsMeHandle(conn netConn.IConnection, buffer []byte) bool

+ func (d *DynamicSpliceSymbol) Receiver(conn netConn.IConnection, buffer []byte) ([]byte, int, bool)

Dec 9, 2020

Changes in this version

+ type DynamicReceiver struct

+ CurrentReceiver netConn.IReceiver

+ IsPackStart bool

+ IsSingle bool

+ Receivers []netConn.IReceiver

+ func NewDynamicReceiver() *DynamicReceiver

+ func (d *DynamicReceiver) Receiver(conn netConn.IConnection, buffer []byte, offset int, count int) (err error)

+ type SpliceSymbolReceiver struct

+ FinishSymbol byte

+ StartSymbol byte

+ func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver

+ func (s *SpliceSymbolReceiver) Receiver(conn netConn.IConnection, buffer []byte) ([]byte, int, bool)