utils

type DefaultBufferedTransportInstance interface {
	ConnectWithContext(ctx context.Context) error
	GetNumBytesAvailableInBuffer() (uint32, error)
	FillBuffer(until func(pos uint, currentByte byte, reader transports.ExtendedReader) bool) error
	PeekReadableBytes(numBytes uint32) ([]byte, error)
	Read(numBytes uint32) ([]byte, error)
}

type DefaultBufferedTransportInstanceRequirements interface {
	GetReader() transports.ExtendedReader
	Connect() error
	IsConnected() bool
}

type Option func(*TransportLogger)

type TransportLogger struct {
	// contains filtered or unexported fields
}