|
|
|
@ -97,12 +97,12 @@ func (r *GosmContainer) WsContainerSend(method WsCommunicationMethod, conn *webs
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (r *GosmContainer) WsContainerReceive[dosthtype (func(interface{}) interface{})| (func([]byte) []byte) ](method WsCommunicationMethod, conn *websocket.Conn, ctx context.Context, dosth dosthtype) (err error, receiveval, sendval interface{}, mtr websocket.MessageType) {
|
|
|
|
|
func (r *GosmContainer) WsContainerReceive(method WsCommunicationMethod, conn *websocket.Conn, ctx context.Context, dosth interface{}) (err error, receiveval, sendval interface{}, mtr websocket.MessageType) {
|
|
|
|
|
switch {
|
|
|
|
|
case method == ReceiveTextMethod || method == ReceiveBinaryMethod:
|
|
|
|
|
err, receiveval, sendval, mtr = WsReceive(ctx, conn, dosth)
|
|
|
|
|
err, receiveval, sendval, mtr = WsReceive(ctx, conn, dosth.(func([]byte) []byte))
|
|
|
|
|
case method == ReceiveJsonMethod:
|
|
|
|
|
err, receiveval, sendval = WsjsonReceive(ctx, conn, dosth)
|
|
|
|
|
err, receiveval, sendval = WsjsonReceive(ctx, conn, dosth.(func(interface{}) interface{}))
|
|
|
|
|
mtr = websocket.MessageText
|
|
|
|
|
default:
|
|
|
|
|
err = errors.New("Wrong communicator method")
|
|
|
|
@ -110,8 +110,6 @@ func (r *GosmContainer) WsContainerReceive[dosthtype (func(interface{}) interfac
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func WsjsonSend(ctx context.Context, conn *websocket.Conn, sendval interface{}) (err error, receiveval interface{}) {
|
|
|
|
|
err = nil
|
|
|
|
|
|
|
|
|
|