revert

websocket.go

@@ -80,8 +80,8 @@ func DialWebsocketWithDialer(ctx context.Context, endpoint, origin string, opts
 		return nil, err
 	}
 	opts.HTTPHeader = header
-	return newClient(ctx, func(ctx context.Context) (ServerCodec, error) {
-		conn, resp, err := websocket.Dial(ctx, endpoint, opts)
+	return newClient(ctx, func(cctx context.Context) (ServerCodec, error) {
+		conn, resp, err := websocket.Dial(cctx, endpoint, opts)
 		if err != nil {
 			hErr := wsHandshakeError{err: err}
 			if resp != nil {

wsjson/wsjson.go

@@ -12,13 +12,13 @@ import (
 var jzon = jsoniter.Config{
 	IndentionStep:                 0,
 	MarshalFloatWith6Digits:       false,
-	EscapeHTML:                    true,
+	EscapeHTML:                    false,
 	SortMapKeys:                   false,
 	UseNumber:                     false,
 	DisallowUnknownFields:         false,
 	TagKey:                        "",
 	OnlyTaggedField:               false,
-	ValidateJsonRawMessage:        true,
+	ValidateJsonRawMessage:        false,
 	ObjectFieldMustBeSimpleString: false,
 	CaseSensitive:                 false,
 }.Froze()
@@ -37,15 +37,12 @@ func read(ctx context.Context, c *websocket.Conn, v interface{}) (err error) {
 	if err != nil {
 		return err
 	}
-
 	b := bufpool.GetStd()
 	defer bufpool.PutStd(b)
-
 	_, err = b.ReadFrom(r)
 	if err != nil {
 		return err
 	}
-
 	err = jzon.Unmarshal(b.Bytes(), v)
 	if err != nil {
 		return fmt.Errorf("failed to unmarshal JSON: %w", err)