|
|
|
@ -101,9 +101,13 @@ func (r *GosmContainer) WsContainerReceive(method WsCommunicationMethod, conn *w
|
|
|
|
|
switch {
|
|
|
|
|
case method == ReceiveTextMethod || method == ReceiveBinaryMethod:
|
|
|
|
|
err, receiveval, sendval, mtr = WsReceive(ctx, conn, dosth.(func([]byte) []byte))
|
|
|
|
|
(*r).CarrierBuffer = receiveval
|
|
|
|
|
(*r).ConvertBuffer2Json()
|
|
|
|
|
case method == ReceiveJsonMethod:
|
|
|
|
|
err, receiveval, sendval = WsjsonReceive(ctx, conn, dosth.(func(interface{}) interface{}))
|
|
|
|
|
mtr = websocket.MessageText
|
|
|
|
|
(*r).CarrierJson = receiveval
|
|
|
|
|
(*r).ConvertJson2Buffer()
|
|
|
|
|
default:
|
|
|
|
|
err = errors.New("Wrong communicator method")
|
|
|
|
|
}
|
|
|
|
|