mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-27 05:15:47 +00:00
make framing parameter required in net.tcp.client
This commit is contained in:
@@ -56,20 +56,19 @@ func init() {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
framingMethod := "RAW"
|
framingMethod, ok := params["framing"]
|
||||||
|
|
||||||
framingMethodRaw, ok := params["framing"]
|
if !ok {
|
||||||
|
return nil, errors.New("net.tcp.client requires a framing parameter")
|
||||||
|
}
|
||||||
|
|
||||||
if ok {
|
framingMethodString, ok := framingMethod.(string)
|
||||||
framingMethodString, ok := framingMethodRaw.(string)
|
|
||||||
|
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, errors.New("net.tcp.client framing method must be a string")
|
return nil, errors.New("net.tcp.client framing method must be a string")
|
||||||
}
|
}
|
||||||
framingMethod = framingMethodString
|
|
||||||
}
|
|
||||||
|
|
||||||
framer := framer.GetFramer(framingMethod)
|
framer := framer.GetFramer(framingMethodString)
|
||||||
|
|
||||||
if framer == nil {
|
if framer == nil {
|
||||||
return nil, fmt.Errorf("net.tcp.client unknown framing method: %s", framingMethod)
|
return nil, fmt.Errorf("net.tcp.client unknown framing method: %s", framingMethod)
|
||||||
|
|||||||
Reference in New Issue
Block a user