|
|
@ -27,7 +27,7 @@ type GosmBuffer []byte |
|
|
|
type GosmAdapter interface { |
|
|
|
Revalue(func(interface{}) interface{}) |
|
|
|
Convert() (GosmAdapter, error) |
|
|
|
//WsCommunicator(string, context.Context, *websocket.Conn, ...func(interface{}) interface{}) (GosmAdapter, error, websocket.MessageType)
|
|
|
|
WsCommunicator(string, context.Context, *websocket.Conn, ...func(interface{}) interface{}) (GosmAdapter, error, websocket.MessageType) |
|
|
|
WsCommunicator(string, context.Context, *websocket.Conn, ...func(interface{}) interface{}) (error, websocket.MessageType) |
|
|
|
} |
|
|
|
|
|
|
@ -127,7 +127,7 @@ func (r *GosmBuffer) WsCommunicator(method string, ctx context.Context, conn *we |
|
|
|
*r = GosmBuffer(receiveval) |
|
|
|
return err, websocket.MessageBinary |
|
|
|
case method == "receive" && len(dosth) == 1: |
|
|
|
err, receiveval, mtr := WsReceive(ctx, conn, nil) //dosth[0]
|
|
|
|
err, receiveval, mtr := WsReceive(ctx, conn, dosth[0]) //
|
|
|
|
*r = GosmBuffer(receiveval) |
|
|
|
return err, mtr |
|
|
|
default: |
|
|
|