fix: fix issue #292

Merge branch 'rc' into v2
feat: add ShuffleCopy
2026-03-01 00:35:28 +08:00 · 2025-02-14 17:35:48 +08:00 · 2025-02-14 17:13:11 +08:00 · 2025-02-14 16:33:22 +08:00 · 2025-02-14 16:23:46 +08:00 · 2025-02-09 23:10:28 +08:00
48 changed files with 1135 additions and 215 deletions
--- a/README.md
+++ b/README.md
@@ -39,7 +39,7 @@
 go get github.com/duke-git/lancet/v2 // will install latest version of v2.x.x
 ```

-2. <b>For users who use version below go1.18, you should install v1.x.x. The latest of v1.x.x is v1.4.5. </b>
+2. <b>For users who use version below go1.18, you should install v1.x.x. The latest of v1.x.x is v1.4.6. </b>

 ```go
 go get github.com/duke-git/lancet // below go1.18, install latest version of v1.x.x
@@ -333,7 +333,7 @@ import "github.com/duke-git/lancet/v2/convertor"
    [[play](https://go.dev/play/p/HwdDPFcza1O)]
 -   **<big>ToBigInt</big>** : converts an integer of any supported type (int, int64, uint64, etc.) to *big.Int.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/convertor.md#ToBigInt)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/X3itkCxwB_x)]

 <h3 id="cryptor"> 6. Cryptor package is for data encryption and decryption.&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -469,10 +469,10 @@ import "github.com/duke-git/lancet/v2/cryptor"
    [[play](https://go.dev/play/p/zutRHrDqs0X)]
 -   **<big>RsaEncrypt</big>** : encrypt data with ras algorithm.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/cryptor.md#RsaEncrypt)]
-    [[play](https://go.dev/play/p/uef0q1fz53I)]
+    [[play](https://go.dev/play/p/7_zo6mrx-eX)]
 -   **<big>RsaDecrypt</big>** : decrypt data with ras algorithm.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/cryptor.md#RsaDecrypt)]
-    [[play](https://go.dev/play/p/uef0q1fz53I)]
+    [[play](https://go.dev/play/p/7_zo6mrx-eX)]
 -   **<big>GenerateRsaKeyPair</big>** : creates rsa private and public key.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/cryptor.md#GenerateRsaKeyPair)]
    [[play](https://go.dev/play/p/sSVmkfENKMz)]
@@ -484,10 +484,10 @@ import "github.com/duke-git/lancet/v2/cryptor"
    [[play](https://go.dev/play/p/sSVmkfENKMz)]
 -   **<big>RsaSign</big>** : signs the data with RSA.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/cryptor.md#RsaSign)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/qhsbf8BJ6Mf)]
 -   **<big>RsaVerifySign</big>** : verifies the signature of the data with RSA.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/cryptor.md#RsaVerifySign)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/qhsbf8BJ6Mf)]

 <h3 id="datetime"> 7. Datetime package supports date and time format and compare. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -633,13 +633,13 @@ import "github.com/duke-git/lancet/v2/datetime"
    [[play](https://go.dev/play/p/6kHBpAxD9ZC)]
 -   **<big>Min</big>** : returns the earliest time among the given times.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#Min)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/MCIDvHNOGGb)]
 -   **<big>Max</big>** : returns the latest time among the given times.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#Max)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/9m6JMk1LB7-)]
 -   **<big>MaxMin</big>** : returns the latest and earliest time among the given times.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#MaxMin)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/rbW51cDtM_2)]

 <h3 id="datastructure"> 8. Datastructure package contains some common data structure. eg. list, linklist, stack, queue, set, tree, graph. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -777,7 +777,7 @@ import "github.com/duke-git/lancet/v2/fileutil"
    [[play](https://go.dev/play/p/teMXnCsdSEw)]
 -   **<big>GetExeOrDllVersion</big>** : Get the version of exe or dll file on windows os.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/fileutil.md#GetExeOrDllVersion)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/iLRrDBhE38E)]

 <h3 id="formatter"> 10. Formatter contains some functions for data formatting. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -1145,16 +1145,16 @@ import "github.com/duke-git/lancet/v2/mathutil"
    [[play](https://go.dev/play/p/WLxDdGXXYat)]
 -   **<big>Variance</big>** : returns the variance of numbers.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/mathutil.md#Variance)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/uHuV4YgXf8F)]
 -   **<big>StdDev</big>** : returns the standard deviation of numbers.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/mathutil.md#StdDev)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/FkNZDXvHD2l)]
 -   **<big>Permutation</big>** : calculates P(n, k).
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/mathutil.md#Permutation)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/MgobwH_FOxj)]
 -   **<big>Combination</big>** : calculates C(n, k).
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/mathutil.md#Combination)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/ENFQRDQUFi9)]

 <h3 id="netutil"> 14. Netutil package contains functions to get net information and send http request. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -1317,7 +1317,7 @@ import "github.com/duke-git/lancet/v2/random"
    [[play](https://go.dev/play/p/68UikN9d6VT)]
 -   **<big>RandNumberOfLength</big>** : generates a random int number of specified length.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/random.md#RandNumberOfLength)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/oyZbuV7bu7b)]

 <h3 id="retry"> 17. Retry package is for executing a function repeatedly until it was successful or canceled by the context. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -1613,10 +1613,10 @@ import "github.com/duke-git/lancet/v2/slice"
    [[play](https://go.dev/play/p/CW3UVNdUZOq)]
 -   **<big>JoinFunc</big>** : joins the slice elements into a single string with the given separator.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#JoinFunc)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/55ib3SB5fM2)]
 -   **<big>ConcatBy</big>** : concats the elements of a slice into a single value using the provided separator and connector function.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#ConcatBy)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/6QcUpcY4UMW)]

 <h3 id="stream"> 19. Stream package implements a sequence of elements supporting sequential and operations. this package is an experiment to explore if stream in go can work as the way java does. its function is very limited. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -1709,10 +1709,10 @@ import "github.com/duke-git/lancet/v2/stream"
    [[play](https://go.dev/play/p/jI6_iZZuVFE)]
 -   **<big>IndexOf</big>** : returns the index of the first occurrence of the specified element in this stream.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/stream.md#IndexOf)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/tBV5Nc-XDX2)]
 -   **<big>LastIndexOf</big>** : returns the index of the last occurrence of the specified element in this stream.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/stream.md#LastIndexOf)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/CjeoNw2eac_G)]

 <h3 id="structs"> 20. Structs package provides several high level functions to manipulate struct, tag, and field. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -1896,7 +1896,7 @@ import "github.com/duke-git/lancet/v2/strutil"
    [[play](https://go.dev/play/p/JZiu0RXpgN-)]
 -   **<big>ExtractContent</big>** : extracts the content between the start and end strings in the source string.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/strutil.md#ExtractContent)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/Ay9UIk7Rum9)]


 <h3 id="system"> 22. System package contain some functions about os, runtime, shell command. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>
@@ -2249,7 +2249,7 @@ import "github.com/duke-git/lancet/v2/xerror"
    [[play](https://go.dev/play/p/acyZVkNZEeW)]
 -   **<big>TryCatch</big>** : simple simulation of Java-style try-catch. 
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/xerror.md#TryCatch)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/D5Mdb0mRj0P)]

 ## How to Contribute

--- a/README_zh-CN.md
+++ b/README_zh-CN.md
@@ -38,7 +38,7 @@
 go get github.com/duke-git/lancet/v2 //安装v2最新版本v2.x.x
 ```

-2. <b>使用 go1.18 以下版本的用户，必须安装 v1.x.x。目前最新的 v1 版本是 v1.4.5。</b>
+2. <b>使用 go1.18 以下版本的用户，必须安装 v1.x.x。目前最新的 v1 版本是 v1.4.6。</b>

 ```go
 go get github.com/duke-git/lancet// 使用go1.18以下版本, 必须安装v1.x.x版本
@@ -333,7 +333,7 @@ import "github.com/duke-git/lancet/v2/convertor"
    [[play](https://go.dev/play/p/HwdDPFcza1O)]
 -   **<big>ToBigInt</big>** : 将整数转为*big.Int。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/convertor.md#ToBigInt)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/X3itkCxwB_x)]

 <h3 id="cryptor"> 6. cryptor 加密包支持数据加密和解密，获取 md5，hash 值。支持 base64, md5, hmac, aes, des, rsa。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -470,10 +470,10 @@ import "github.com/duke-git/lancet/v2/cryptor"
    [[play](https://go.dev/play/p/zutRHrDqs0X)]
 -   **<big>RsaEncrypt</big>** : 用公钥文件 ras 加密数据。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/cryptor.md#RsaEncrypt)]
-    [[play](https://go.dev/play/p/uef0q1fz53I)]
+    [[play](https://go.dev/play/p/7_zo6mrx-eX)]
 -   **<big>RsaDecrypt</big>** : 用私钥文件 rsa 解密数据。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/cryptor.md#RsaDecrypt)]
-    [[play](https://go.dev/play/p/uef0q1fz53I)]
+    [[play](https://go.dev/play/p/7_zo6mrx-eX)]
 -   **<big>GenerateRsaKeyPair</big>** : 创建rsa公钥私钥和key。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/cryptor.md#GenerateRsaKeyPair)]
    [[play](https://go.dev/play/p/sSVmkfENKMz)]
@@ -485,10 +485,10 @@ import "github.com/duke-git/lancet/v2/cryptor"
    [[play](https://go.dev/play/p/sSVmkfENKMz)]
 -   **<big>RsaSign</big>** : 应用RSA算法签名数据。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/cryptor.md#RsaSign)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/qhsbf8BJ6Mf)]
 -   **<big>RsaVerifySign</big>** : 验证数据的签名是否符合RSA算法。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/cryptor.md#RsaVerifySign)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/qhsbf8BJ6Mf)]

 <h3 id="datetime"> 7. datetime日期时间处理包，格式化日期，比较日期。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -635,13 +635,13 @@ import "github.com/duke-git/lancet/v2/datetime"
    [[play](https://go.dev/play/p/6kHBpAxD9ZC)]
 -   **<big>Min</big>** : 返回最早时间。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#Min)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/MCIDvHNOGGb)]
 -   **<big>Max</big>** : 返回最晚时间。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#Max)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/9m6JMk1LB7-)]
 -   **<big>MaxMin</big>** : 返回最早和最晚时间。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#MaxMin)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/rbW51cDtM_2)]


 <h3 id="datastructure"> 8. datastructure 包含一些普通的数据结构实现。例如：list, linklist, stack, queue, set, tree, graph。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
@@ -776,7 +776,7 @@ import "github.com/duke-git/lancet/v2/fileutil"
    [[play](https://go.dev/play/p/teMXnCsdSEw)]
 -   **<big>GetExeOrDllVersion</big>** : 返回exe,dll文件版本号(仅Window平台)。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/fileutil.md#GetExeOrDllVersion)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/iLRrDBhE38E)]


 <h3 id="formatter"> 10. formatter 格式化器包含一些数据格式化处理方法。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
@@ -1145,16 +1145,16 @@ import "github.com/duke-git/lancet/v2/mathutil"
    [[play](https://go.dev/play/p/WLxDdGXXYat)]
 -   **<big>Variance</big>** : 计算方差。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/mathutil.md#Variance)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/uHuV4YgXf8F)]
 -   **<big>StdDev</big>** : 计算标准差。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/mathutil.md#StdDev)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/FkNZDXvHD2l)]
 -   **<big>Permutation</big>** : 计算排列数P(n, k)。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/mathutil.md#Permutation)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/MgobwH_FOxj)]
 -   **<big>Combination</big>** : 计算组合数C(n, k)。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/mathutil.md#Combination)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/ENFQRDQUFi9)]

 <h3 id="netutil"> 14. netutil 网络包支持获取 ip 地址，发送 http 请求。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -1317,7 +1317,7 @@ import "github.com/duke-git/lancet/v2/random"
    [[play](https://go.dev/play/p/68UikN9d6VT)]
 -   **<big>RandNumberOfLength</big>** : 生成指定长度的随机数。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/random.md#RandNumberOfLength)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/oyZbuV7bu7b)]

 <h3 id="retry"> 17. retry 重试执行函数直到函数运行成功或被 context cancel。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -1610,10 +1610,10 @@ import "github.com/duke-git/lancet/v2/slice"
    [[play](https://go.dev/play/p/CW3UVNdUZOq)]
 -   **<big>JoinFunc</big>** : 将切片元素用给定的分隔符连接成一个单一的字符串。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#JoinFunc)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/55ib3SB5fM2)]
 -   **<big>ConcatBy</big>** : 将切片中的元素连接成一个值，使用指定的分隔符和连接器函数。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#ConcatBy)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/6QcUpcY4UMW)]

 <h3 id="stream"> 19. stream 流，该包仅验证简单的 stream 实现，功能有限。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -1706,10 +1706,10 @@ import "github.com/duke-git/lancet/v2/stream"
    [[play](https://go.dev/play/p/jI6_iZZuVFE)]
 -   **<big>IndexOf</big>** : 返回在stream中找到值的第一个匹配项的索引，如果找不到值，则返回-1。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/stream.md#IndexOf)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/tBV5Nc-XDX2)]
 -   **<big>LastIndexOf</big>** : 返回在stream中找到值的最后一个匹配项的索引，如果找不到值，则返回-1。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/stream.md#LastIndexOf)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/CjeoNw2eac_G)]

 <h3 id="structs"> 20. structs 提供操作 struct, tag, field 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -1896,7 +1896,7 @@ import "github.com/duke-git/lancet/v2/strutil"
    [[play](https://go.dev/play/p/JZiu0RXpgN-)]
 -   **<big>ExtractContent</big>** : 提取两个标记之间的内容。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/strutil.md#ExtractContent)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/Ay9UIk7Rum9)]

 <h3 id="system"> 22. system 包含 os, runtime, shell command 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

@@ -2249,7 +2249,7 @@ import "github.com/duke-git/lancet/v2/xerror"
    [[play](https://go.dev/play/p/acyZVkNZEeW)]
 -   **<big>TryCatch</big>** : 简单实现的java风格异常处理（try-catch-finally）。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/xerror.md#TryCatch)]
-    [[play](https://go.dev/play/p/todo)]
+    [[play](https://go.dev/play/p/D5Mdb0mRj0P)]

 ## 如何贡献代码

--- a/concurrency/channel.go
+++ b/concurrency/channel.go
@@ -157,10 +157,10 @@ func (c *Channel[T]) Tee(ctx context.Context, in <-chan T) (<-chan T, <-chan T)
 // Play: https://go.dev/play/p/qmWSy1NVF-Y
 func (c *Channel[T]) Bridge(ctx context.Context, chanStream <-chan <-chan T) <-chan T {
 	valStream := make(chan T)
-
 	go func() {
 		defer close(valStream)
-
+		wg := sync.WaitGroup{}
+		defer wg.Wait()
 		for {
 			var stream <-chan T
 			select {
@@ -169,19 +169,22 @@ func (c *Channel[T]) Bridge(ctx context.Context, chanStream <-chan <-chan T) <-c
 					return
 				}
 				stream = maybeStream
+				wg.Add(1)
 			case <-ctx.Done():
 				return
 			}

-			for val := range c.OrDone(ctx, stream) {
-				select {
-				case valStream <- val:
-				case <-ctx.Done():
+			go func() {
+				defer wg.Done()
+				for val := range c.OrDone(ctx, stream) {
+					select {
+					case valStream <- val:
+					case <-ctx.Done():
+					}
 				}
-			}
+			}()
 		}
 	}()
-
 	return valStream
 }

--- a/concurrency/channel_example_test.go
+++ b/concurrency/channel_example_test.go
@@ -168,7 +168,8 @@ func ExampleChannel_Tee() {
 func ExampleChannel_Bridge() {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
-
+	m1 := make(map[int]int)
+	m2 := make(map[int]int)
 	c := NewChannel[int]()
 	genVals := func() <-chan <-chan int {
 		out := make(chan (<-chan int))
@@ -177,6 +178,7 @@ func ExampleChannel_Bridge() {
 			for i := 1; i <= 5; i++ {
 				stream := make(chan int, 1)
 				stream <- i
+				m1[i]++
 				close(stream)
 				out <- stream
 			}
@@ -185,12 +187,15 @@ func ExampleChannel_Bridge() {
 	}

 	for v := range c.Bridge(ctx, genVals()) {
-		fmt.Println(v)
+		m2[v]++
+	}
+	for k, v := range m1 {
+		fmt.Println(m2[k] == v)
 	}
 	// Output:
-	// 1
-	// 2
-	// 3
-	// 4
-	// 5
+	// true
+	// true
+	// true
+	// true
+	// true
 }
--- a/concurrency/channel_test.go
+++ b/concurrency/channel_test.go
@@ -169,7 +169,8 @@ func TestTee(t *testing.T) {
 func TestBridge(t *testing.T) {
 	t.Parallel()
 	assert := internal.NewAssert(t, "TestBridge")
-
+	m1 := make(map[int]int)
+	m2 := make(map[int]int)
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()

@@ -181,6 +182,7 @@ func TestBridge(t *testing.T) {
 			for i := 0; i < 10; i++ {
 				stream := make(chan int, 1)
 				stream <- i
+				m1[i]++
 				close(stream)
 				chanStream <- stream
 			}
@@ -188,9 +190,11 @@ func TestBridge(t *testing.T) {
 		return chanStream
 	}

-	index := 0
 	for val := range c.Bridge(ctx, genVals()) {
-		assert.Equal(index, val)
-		index++
+		m2[val]++
+	}
+
+	for k, v := range m1 {
+		assert.Equal(m2[k], v)
 	}
 }
--- a/convertor/convertor.go
+++ b/convertor/convertor.go
@@ -108,6 +108,13 @@ func ToString(value any) string {
 	if value == nil {
 		return ""
 	}
+	rv := reflect.ValueOf(value)
+	if rv.Kind() == reflect.Ptr {
+		if rv.IsNil() {
+			return ""
+		}
+		return ToString(rv.Elem().Interface())
+	}

 	switch val := value.(type) {
 	case float32:
@@ -143,12 +150,8 @@ func ToString(value any) string {
 		if err != nil {
 			return ""
 		}
-		return string(b)

-		// todo: maybe we should't supprt other type conversion
-		// v := reflect.ValueOf(value)
-		// log.Panicf("Unsupported data type: %s ", v.String())
-		// return ""
+		return string(b)
 	}
 }

@@ -486,7 +489,7 @@ func ToRawUrlBase64(value any) string {
 }

 // ToBigInt converts an integer of any supported type (int, int64, uint64, etc.) to *big.Int
-// Play: todo
+// Play: https://go.dev/play/p/X3itkCxwB_x
 func ToBigInt[T any](v T) (*big.Int, error) {
 	result := new(big.Int)

--- a/convertor/convertor_test.go
+++ b/convertor/convertor_test.go
@@ -142,13 +142,24 @@ func TestToString(t *testing.T) {
 	}
 	aStruct := TestStruct{Name: "TestStruct"}

+	i32Val := int32(123)
+	i64Val := int64(123)
+	iZeroVal := 0
+	fVal := 12.3
+	sVal := "abc"
+	var iNilPointer *int
+	var sNilPointer *string
+
 	cases := []any{
 		"", nil,
 		int(0), int8(1), int16(-1), int32(123), int64(123),
 		uint(123), uint8(123), uint16(123), uint32(123), uint64(123),
 		float64(12.3), float32(12.3),
 		true, false,
-		[]int{1, 2, 3}, aMap, aStruct, []byte{104, 101, 108, 108, 111}}
+		[]int{1, 2, 3}, aMap, aStruct, []byte{104, 101, 108, 108, 111},
+		&i32Val, &i64Val, &fVal, &sVal, &aStruct, iNilPointer, sNilPointer,
+		&iZeroVal,
+	}

 	expected := []string{
 		"", "",
@@ -157,6 +168,8 @@ func TestToString(t *testing.T) {
 		"12.3", "12.3",
 		"true", "false",
 		"[1,2,3]", "{\"a\":1,\"b\":2,\"c\":3}", "{\"Name\":\"TestStruct\"}", "hello",
+		"123", "123", "12.3", "abc", "{\"Name\":\"TestStruct\"}", "", "",
+		"0",
 	}

 	for i := 0; i < len(cases); i++ {
--- a/cryptor/crypto.go
+++ b/cryptor/crypto.go
@@ -565,7 +565,7 @@ func GenerateRsaKey(keySize int, priKeyFile, pubKeyFile string) error {
 }

 // RsaEncrypt encrypt data with ras algorithm.
-// Play: https://go.dev/play/p/rDqTT01SPkZ
+// Play: https://go.dev/play/p/7_zo6mrx-eX
 func RsaEncrypt(data []byte, pubKeyFileName string) []byte {
 	file, err := os.Open(pubKeyFileName)
 	if err != nil {
@@ -600,7 +600,7 @@ func RsaEncrypt(data []byte, pubKeyFileName string) []byte {
 }

 // RsaDecrypt decrypt data with ras algorithm.
-// Play: https://go.dev/play/p/rDqTT01SPkZ
+// Play: https://go.dev/play/p/7_zo6mrx-eX
 func RsaDecrypt(data []byte, privateKeyFileName string) []byte {
 	file, err := os.Open(privateKeyFileName)
 	if err != nil {
@@ -663,7 +663,7 @@ func RsaDecryptOAEP(ciphertext []byte, label []byte, key rsa.PrivateKey) ([]byte
 }

 // RsaSign signs the data with RSA.
-// Play: todo
+// Play: https://go.dev/play/p/qhsbf8BJ6Mf
 func RsaSign(hash crypto.Hash, data []byte, privateKeyFileName string) ([]byte, error) {
 	privateKey, err := loadRasPrivateKey(privateKeyFileName)
 	if err != nil {
@@ -679,7 +679,7 @@ func RsaSign(hash crypto.Hash, data []byte, privateKeyFileName string) ([]byte,
 }

 // RsaVerifySign verifies the signature of the data with RSA.
-// Play: todo
+// Play: https://go.dev/play/p/qhsbf8BJ6Mf
 func RsaVerifySign(hash crypto.Hash, data, signature []byte, pubKeyFileName string) error {
 	publicKey, err := loadRsaPublicKey(pubKeyFileName)
 	if err != nil {
@@ -712,7 +712,6 @@ func loadRsaPublicKey(filename string) (*rsa.PublicKey, error) {
 	if blockType == "RSA PUBLIC KEY" {
 		pubKey, err = x509.ParsePKCS1PublicKey(block.Bytes)
 		if err != nil {
-			// todo: here should be a bug, should return nil, err
 			key, err := x509.ParsePKIXPublicKey(block.Bytes)
 			if err != nil {
 				return nil, err
--- a/cryptor/rsa_private_example.pem
+++ b/cryptor/rsa_private_example.pem
@@ -1,51 +1,51 @@
 -----BEGIN rsa private key-----
-MIIJJwIBAAKCAgEAwGdN8KE2NTK41cVN7i6mZZS5J86gjNs0LJDHylb2GG+K4O8s
-fq98EMKMJ2xGnKoVRJXucVohr5Eiuf5zgxQe9mpYDyDQ0vnpBkoNkfzJNZQvcQFa
-IllUeH+eN4hSBhMegPspCr2BcmC/m/N40+PjBMDaHSzeNE2SyIuyflLC7GhQvHnk
-cQXkqJVNC1yesV7zYKDV/xYPI0NxN0kE+4eR650A77jso4gloRUek0cpU4ztpe6Z
-z4za7AEKHmZO8pVHpQJihbNMhItbo6BcgeOFWImXyJfcbCtu1ayciaJ0Q45Z1btu
-F2wFwQjwZGt7DAvbzYwMBBiTpGxig/8kzibm7bL1Td7huW6Knqbfh4/v+2m+2aNK
-1u0TfncFUr17wDDfeVj/xeNOSbPu2X/AppjVX0rxmvWN+AByFfAuw7/kqMK7QZlA
-+5nNjmOojvryGOSu1he4PUnhRyJ7jofOIrLZ9YYBXpRiY/WB8t+xWIlaoPXFmsOx
-SgMwzQFGMlnSFy7nK9T4znE0QFknOQNbELPEB4UGLOEa5Tg6YD2ORDDSqCzMRdkE
-1kAgoMRC9DkRXE45KEcQlhMX9Pahwx3mPS4lMWABVudiEWyhGaR279OWjezqvtoL
-LBJ5GD9QL1XqaqCaJjp+qsHmX8re+MTA3ZJuyUtRoPXPsKCe2nZ6Ma87DlUCAwEA
-AQKCAgAWT+SJ8ygGI0ur/qV66Y4CWazfIOcdbo4uXNvOayc+zjCcxR+z0UXh6621
-JKlLoa21tm1gV8NwSLRuPUPH/51Xlh2AI54T2Udco1nPhDERNY4K3M1HDnTtRF9k
-sTpR2gW/j2DDDhbk3LNbsnBgohzBgFvK5lkeV6CeARVB8PcJ008JjFkhgj1yD15P
-4v3EM+6lVgF7A2PeAwQuFRmu0ZnqaNqi8h7/F9rFQ124VphESCOHCpRrrTn2BGjX
-/aVKHGWijRQ/zPsio8aMwxv3NBtSmSIw8Otu39qKjOnaTCyPaQKh9opdzPkd2ZuH
-Ca/LRdTHkWYTU4ZLmwYRqJTsEzbURlaTULIvsUjVAjHJd3derDeFrBOa8txYqzQi
-HSKk52vC5mhfeGYmm415SQGhsL1blxuQE6yoAClNeY+16FSjIoZOcFBA46xkc6I/
-y3nWNcJOTcYkYOpb/R2voDabAen98sZHdcD/V86wNAt/JtwdUveeBKCX7YPtAMhu
-3m6Me5c8b7F5dRTe0bnzdjjaReywooW9+XGRhbmPijqiPBjsHb8dfkZW9vtkyORL
-l8wtMvowTDLxJPB1qgPZDOFpsY/0whZpZi14vNnmGjaFRNrwWwqF5eWBy+eGsQpj
-VsvAx9PqTwkoof37h1xkdPT9Ft6T5X6gl+l83H9y9XVksenAQQKCAQEA1HRmshIk
-RSlGrLrVqiAnndRAHV6flhKsF0+1IOzr7dL7WVfVNoQV2jPcaHGW+bZoi4hP8kIj
-YXo2IBF6xSiPiIksJJ2xBmFY+afu/HLtBMwwNhF3oFGunu8ab/ZEDlLg2oRQ1616
-229MCRvgGSM59Q3JTZF0svSHu4xGZvIriRw2g500fTKh9+YiNl1hTeCp3A4f/MKl
-mo4XvFgcIC9DdfMrb0ST/RtnM9vLCIXYl5ej862PcWD0y2FbvpXtD+WA05bWUsPW
-PBseF6PUKC1IgVMo7oCBAkmnth5gkK1+a6cdZ5j+LC+q5rmK+cDa5IIJzCbXapuA
-f6NrRSd18203EwKCAQEA59bPN2eNf90W7pi2+bmGETtgz/wl4DBmVH/PsOCuMlGr
-MnnufkBD9ig7ZAK1iZhZw3tgDrlh7rBGHdFPtwLad9tH5MhwK39WSfqUwLt6CRjx
-3s6U61riGQzVLKb8iWlxek1IE7s0y/3m4YH17wdLjCOTEe1Jyi1dXcu3+oHGqFy+
-HJyBesyroaHswcwV1tUh3QgzuT6McJEolEVdu6XPvXnerYd+LNgYiz8gsrViU8E0
-WKrLnvdRMnn3ySJH7wkLBdeFi8N0glrEcF/Kcbyh6vTKuQkPzIC7szIy+Yvkinva
-6fSBoeL72i2najXWFhZsXJbpHxMmw95ZeC7SH4/J9wKCAQAaK7CO1O9E2b3L/0Pc
-rhNTPNcdBw/vg6NRR89PHABADpJJwikQixrKA0NuVje70P112rfGZuFG27AZKS4P
-ZVyw+/zFEevBlnJIZqhozptl0OVLc8FhrU4uY9PE4PgnL4xlPpFa0BLnPwGFybpE
-PnOgPS+D75wJg1fJAZGWktRMEn6gndfeaENNbzrdqYkX98nUwqSsFSojLMe9urjU
-Oh48RFUgYrk8H4kJ+VQ8W4h/u/1FQib+V2wwNXEAvCU0pRfGeLkz/s3AH7MIRHUY
-8eMRkzXik0/RAVO4emt4xvZgunhDz7PXq5OI0mhNNbWBGoesb0hv6HHexzmqjh7Y
-eqajAoIBAFiIpJsw1U1l3bMB6KYW3gbImSDz1nb1pK5SHLscIgmfPHRLMfNOkWV4
-Wa3IhxDjeCv5emZFDwv6jtwmKX3m/gzVVXAdxxAlUYtwwMuVDHZa60q9swrpqvwL
-9YBWyIulE6uzxXmbfP8Fl9y4J3W/YG9Eyo4HAq3NgyElgb2NP5Ldz8/XSG7fqA9S
-abpcOF7RB1yEHFR6eWEnXcq5bqERIfLmjk3QNzPi1gSe99qm/8SiPF474wRyx7Qx
-9Zj+mV/EIUx60EneOyjohqmvOv0SHvc9wgjFWB4tbwBwhBzd+kmUILZFJBfxOWJJ
-GuypYHcQ2xLEooO2aZBU4e/OWXmqDGMCggEAU+t1zgjUM2MTUMYDQry49j0SEQmc
-nGAxhpUxwWHH9LDJeMiD/Tb5DMlqSUwpl5CMCWyvieoG+dyydIT9T3NRa9j+8ga3
-MSVrpDtM8O6m1t/8TdbWHFH/En48KNAIQFP5DOLydF0zIfNzLlhlDn03HoIKf5XD
-mcoKiuqr9ycnh1Yp6ns9EJLRMBR2w5yJXE0eAMfj2De+GQFUzSRfHkCFSs5kK+Wp
-JGzruiS0pX24KrTV4boOfhc9yNOJ+p/1t/lbBdp0ruEeATzQO2XaUvyY2iyctllp
-fOQtpLwQSFnxDn/hkd9R/fQThQzcXinqCAv8db1hYUR4sVTmPH9lYjW2Og==
+MIIJKQIBAAKCAgEAof7+5KVH6s/ID7onVeuCPVGPIW6TiHHjDlxbYLdA/CyhTvR2
+Pk8JvX9BjBXLI/+jTWsyTUucwszu3MaVhIS/gzoLKjr5meVp+HEcFe98s4XRYhob
+2cdpDo+Jty8Vuodz5T2nYkIZP/oyJNmQCBYDe20nBwmjjFfworEvwNy2fSucs8wr
+lJT2Xqy4oHZqERWvnIJZtBshX9//9Pw3m/GupHeBFBNW2omWCQm4aTEbeepkXloT
+gVQ75FEpyyjNjDi+OG/Om2v5l+XCvOcV39Hc7sBovDFNX6w39zQSIKiMpFkxciKP
+9SPbqZz+Vv0iyUPKxi2gXwbgy0+k2aTQlsPS976+2/4QgLReU3Ujeh8Q6oRwB8HR
+fPlD7aY+dGPMT16o1R3nhs2jwsGId812lw5qgjaYZJCXCBhQcZFs+1IM7c6GmIGX
+YIAcFDWiVsENqqesQO5tCA1UTTGtIa9kMYD/pwFK1ANVvrr2c6Qu/0UuBneawok7
+6vDHTQCWmVcF0QIe5RaTj8YK9TaNAcQDPy9jM0jWxJE1EBuRpDtIymQIcgMpXwgu
+erh9NuXNoGEVPn4mvlVfy+1TVGzws8WsZwY/LH07afdfIeDc1YwLadwq5S+wxuzw
+NuSCM9t2rIzfbRhorlg/lVDWqP8H6d9vF5MJY9kSiO3KgCSJLYfVl+Q+8asCAwEA
+AQKCAgAdzYTlWcb+WxWqVwwPkZFXaJ7VfrtjudgU90bUZ0JsYmWW2gC6+92F4FiV
+xhimWcyYXKVXdRa0+/Dh6yLsy2NUaCRPs6Ph/UPesiiBnJqriG36B2WiTj50sFGc
+wuvTckIPJaWavSBaFdSN1Pzbj/k6Bt3MPKi7FB6wP7rSV4i3RIPCzEgkQLeGuW4K
+D176H6w8Nfr82JTuR46WaqRsay0/EsFLiTdMY02YAhLMP32Xk1i9xwKZo36VRZ1T
+xAD00CemyGMRUu8LU/jcugLbN4fW4M0j+koK1OtC7nB7U6b0QXiIT/V+Gwe5j6l3
+JYD12CQBC7naYbCPlup0JA8//WzdXlnh5Tix8XfSVC7hx+0e4caAKJZNHXYEiXY/
+7N2Eg77+zk1h+K8oD+8/UCQRSvox1867GkeUd+yDQGpIFr42dM5fSupHt8wV7Etm
+Oap8yI2eX+NUr+gZcMlpaNt3bVFfAQNPrMmMqAsJvlGLTMiniLJ5gE5GhRp+A+03
+mCmokS92qa9E2m9GyaSYWlu37VnMgFeoLxgEj3tiVmiHiXbtReM2F2SLybS/kHxx
+XrgeqlU85J6C7P9ggxEoph2OxGz5+DuinQL2V/JPrV2JhTGEcTHqbV2lN3yfCKj7
+uyzmS7wPTmyM5iJCnDj+DRVC6Od3BRYeh7ohte40zBsNZFLZYQKCAQEAwzrjWUoQ
+ORa/kSA+n1d4CpDPcYX93JhKLPCmSDvE1MJqNE0uqfSbHajtt9XNrRMjmZ7Godnm
+pzMS9hpVc3+DOt4uNOn0I0AY6fbZY4Wn/PJkqRe7RcCeLvvkKu6m4qGmapbu84xl
+FwjQhMksglrx96uB8YIvvtsypyxJvdxYuB7TXnQHU8uXqFgmBkwu+/VmUE/xqIe/
+yEh6LQ9Yiqee9U/WGQwLmupVr0kvixlNP1tlT52ISdD4+3vuUlOlVIcdXefknih4
+tOiUkOWx+u4sIyQ++d0cf1CyMAX8vStikepNoiafGbpRT0ON/EpBC8Aimn15WOUk
+rhBFkQA874628QKCAQEA1GvTH6f9Du9svOXeYJmEgTBkpSwvWLv81McpZ6cErvt9
+YOIKYndGvmhABHFi9Cy9E5FITUBU2zFNmd4idgS9FfcZx6TPibpKp46lHHW4Pwa+
+qXjJ1Xerre938Yh0HeTM7AIUUrTfZHMb7Ymr+8rQW3T90jnJuzCji28eoMzhemNw
+wK5qiTfjC7mKS1WOxCfCAwiLCtCGSaW94WfL3/4vFGEKgMwJBj/FI34uJCbYVHmI
+wZKg0Tdf3xCv+oz9spLfYyaz0AobiCGzBw3gaxlQl2FqeQzOUQal+KQf78scXlBz
+eHZxB9gFl3FrR3thuZ7SyAnTj4gCj6JxT3tySEaKWwKCAQEAuhi9NJTT6AdWLjmF
+WBBhvfiRtU4bUhbcxf/TEZHfq0tzP02/SISBBAHOL+me9/cBfWMLRqbWJdUaovsx
+LzqCVjAJ7aiBbsSfuw3x5Ns36XcJGuIjQnc8kd7MfVwmOmwKnRooxoGyrwVY9upp
+Ag09D3AuGo+VgaGipBYkaNXMwB2qMCP8BBVTCEaWYHRoaQZgM/gwjAxydLEZvTAe
+n3TuojorBI8l1NLBQKhLqJVCvD0b0ouAqZSIcfiNkW5ob62oAaaVl2lOvmvhiklZ
+oa885XacjUMG8hly8TIT3CKqABtPS1zzVevzq9HiW3ZQkKnikk8+x80NbNrX5UNL
+0rLAkQKCAQEAyqpBGN/OqbQ225a47xMo/5TrQUeBuLhKhbuqvlD0P/qDaa7f14gT
+P9D42wRPM8WHc6bWA5ZQH3zPm/D6kfz9ZnqF5xtQQwgw9+I5l4idC8zklY4/iuIN
+MvrZReE5X9gOx1FIkIwu4oiMabpDEw0ycz+Qd0VZObYzIvIWl7ZBneJIDh2aWWav
+wVz5G9z6RB3mlbxN5DiFFrkCC49bTU8XHetj+PQx2/t1m+JkJWvGU/pMRtsdgd7C
+InGqZHKmDfzhEpk3T1KFaAE27JEJv0S8xmFUEz/rjBS6vxnfuonffABn2tOuDZzF
+4PJ+Nwn5d/6W/fGaHkPWpbGHSBzwMRLUJwKCAQBiPAfbLKuB9u2HFxV33lQuBlMi
+HK6JhLoN0o0I5ICuC01IlOaAjAbdTAZdNXcuj9JPfS4tuLG3+nRueKJ5A7MHvwDG
+ZBvVq1q8kKnEl04yW4J/2SfjFk+Do2V3WR8vYjphOgd2pXP72IRw5YWW087VCKFY
+x2Cjuluapss8zdPR6lBxrrdvSCoysW154ALchgUeJAv4G9x/KPQBoBUkDXO4R6UJ
+a36nUMBO7XjkFeucU9npdOl9UEz3ZOE9mWLtck60lZofHoS/dPaY7hzAjetbtfDs
+J8sSwmHsb1DdOx5YSpEkg9aPrtShkChYoKOJFLKhpf7WGbVx2U7OBw71BCa5
 -----END rsa private key-----
--- a/cryptor/rsa_public_example.pem
+++ b/cryptor/rsa_public_example.pem
@@ -1,14 +1,14 @@
 -----BEGIN rsa public key-----
-MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAwGdN8KE2NTK41cVN7i6m
-ZZS5J86gjNs0LJDHylb2GG+K4O8sfq98EMKMJ2xGnKoVRJXucVohr5Eiuf5zgxQe
-9mpYDyDQ0vnpBkoNkfzJNZQvcQFaIllUeH+eN4hSBhMegPspCr2BcmC/m/N40+Pj
-BMDaHSzeNE2SyIuyflLC7GhQvHnkcQXkqJVNC1yesV7zYKDV/xYPI0NxN0kE+4eR
-650A77jso4gloRUek0cpU4ztpe6Zz4za7AEKHmZO8pVHpQJihbNMhItbo6BcgeOF
-WImXyJfcbCtu1ayciaJ0Q45Z1btuF2wFwQjwZGt7DAvbzYwMBBiTpGxig/8kzibm
-7bL1Td7huW6Knqbfh4/v+2m+2aNK1u0TfncFUr17wDDfeVj/xeNOSbPu2X/AppjV
-X0rxmvWN+AByFfAuw7/kqMK7QZlA+5nNjmOojvryGOSu1he4PUnhRyJ7jofOIrLZ
-9YYBXpRiY/WB8t+xWIlaoPXFmsOxSgMwzQFGMlnSFy7nK9T4znE0QFknOQNbELPE
-B4UGLOEa5Tg6YD2ORDDSqCzMRdkE1kAgoMRC9DkRXE45KEcQlhMX9Pahwx3mPS4l
-MWABVudiEWyhGaR279OWjezqvtoLLBJ5GD9QL1XqaqCaJjp+qsHmX8re+MTA3ZJu
-yUtRoPXPsKCe2nZ6Ma87DlUCAwEAAQ==
+MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAof7+5KVH6s/ID7onVeuC
+PVGPIW6TiHHjDlxbYLdA/CyhTvR2Pk8JvX9BjBXLI/+jTWsyTUucwszu3MaVhIS/
+gzoLKjr5meVp+HEcFe98s4XRYhob2cdpDo+Jty8Vuodz5T2nYkIZP/oyJNmQCBYD
+e20nBwmjjFfworEvwNy2fSucs8wrlJT2Xqy4oHZqERWvnIJZtBshX9//9Pw3m/Gu
+pHeBFBNW2omWCQm4aTEbeepkXloTgVQ75FEpyyjNjDi+OG/Om2v5l+XCvOcV39Hc
+7sBovDFNX6w39zQSIKiMpFkxciKP9SPbqZz+Vv0iyUPKxi2gXwbgy0+k2aTQlsPS
+976+2/4QgLReU3Ujeh8Q6oRwB8HRfPlD7aY+dGPMT16o1R3nhs2jwsGId812lw5q
+gjaYZJCXCBhQcZFs+1IM7c6GmIGXYIAcFDWiVsENqqesQO5tCA1UTTGtIa9kMYD/
+pwFK1ANVvrr2c6Qu/0UuBneawok76vDHTQCWmVcF0QIe5RaTj8YK9TaNAcQDPy9j
+M0jWxJE1EBuRpDtIymQIcgMpXwguerh9NuXNoGEVPn4mvlVfy+1TVGzws8WsZwY/
+LH07afdfIeDc1YwLadwq5S+wxuzwNuSCM9t2rIzfbRhorlg/lVDWqP8H6d9vF5MJ
+Y9kSiO3KgCSJLYfVl+Q+8asCAwEAAQ==
 -----END rsa public key-----
--- a/datetime/datetime.go
+++ b/datetime/datetime.go
@@ -445,7 +445,7 @@ func GenerateDatetimesBetween(start, end time.Time, layout string, interval stri
 }

 // Min returns the earliest time among the given times.
-// Play: todo
+// Play: https://go.dev/play/p/MCIDvHNOGGb
 func Min(t1 time.Time, times ...time.Time) time.Time {
 	minTime := t1

@@ -459,7 +459,7 @@ func Min(t1 time.Time, times ...time.Time) time.Time {
 }

 // Max returns the latest time among the given times.
-// Play: todo
+// Play: https://go.dev/play/p/9m6JMk1LB7-
 func Max(t1 time.Time, times ...time.Time) time.Time {
 	maxTime := t1

@@ -473,7 +473,7 @@ func Max(t1 time.Time, times ...time.Time) time.Time {
 }

 // MaxMin returns the latest and earliest time among the given times.
-// Play: todo
+// Play: https://go.dev/play/p/rbW51cDtM_2
 func MaxMin(t1 time.Time, times ...time.Time) (maxTime time.Time, minTime time.Time) {
 	maxTime = t1
 	minTime = t1
--- a/docs/api/packages/convertor.md
+++ b/docs/api/packages/convertor.md
@@ -373,7 +373,7 @@ import (

 func main() {
    aMap := map[string]int{"a": 1, "b": 2, "c": 3}
-    result, err := ToJson(aMap)
+    result, err := convertor.ToJson(aMap)

    if err != nil {
        fmt.Printf("%v", err)
@@ -1155,7 +1155,7 @@ func main() {

 <p>将整数值转换为bigInt。</p>

-<b>函数签名:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>函数签名:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/X3itkCxwB_x)</span></b>

 ```go
 func ToBigInt[T any](v T) (*big.Int, error)
--- a/docs/api/packages/cryptor.md
+++ b/docs/api/packages/cryptor.md
@@ -1436,7 +1436,7 @@ func main() {
 func RsaEncrypt(data []byte, pubKeyFileName string) []byte
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/uef0q1fz53I)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/7_zo6mrx-eX)</span></b>

 ```go
 package main
@@ -1473,7 +1473,7 @@ func main() {
 func RsaDecrypt(data []byte, privateKeyFileName string) []byte
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/uef0q1fz53I)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/7_zo6mrx-eX)</span></b>

 ```go
 package main
@@ -1621,7 +1621,7 @@ func main() {
 func RsaSign(hash crypto.Hash, data []byte, privateKeyFileName string) ([]byte, error)
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/qhsbf8BJ6Mf)</span></b>

 ```go
 package main
@@ -1638,12 +1638,12 @@ func main() {
    privateKey := "./rsa_private.pem"
    publicKey := "./rsa_public.pem"

-    signature, err := RsaSign(hash, data, privateKey)
+    signature, err := cryptor.RsaSign(hash, data, privateKey)
    if err != nil {
        return
    }

-    err = RsaVerifySign(hash, data, signature, publicKey)
+    err = cryptor.RsaVerifySign(hash, data, signature, publicKey)
    if err != nil {
        return
    }
@@ -1660,7 +1660,7 @@ func main() {
 func RsaVerifySign(hash crypto.Hash, data, signature []byte, pubKeyFileName string) error
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/qhsbf8BJ6Mf)</span></b>

 ```go
 package main
@@ -1677,12 +1677,12 @@ func main() {
    privateKey := "./rsa_private.pem"
    publicKey := "./rsa_public.pem"

-    signature, err := RsaSign(hash, data, privateKey)
+    signature, err := cryptor.RsaSign(hash, data, privateKey)
    if err != nil {
        return
    }

-    err = RsaVerifySign(hash, data, signature, publicKey)
+    err = cryptor.RsaVerifySign(hash, data, signature, publicKey)
    if err != nil {
        return
    }
--- a/docs/api/packages/datetime.md
+++ b/docs/api/packages/datetime.md
@@ -1585,7 +1585,7 @@ func main() {
 func Min(t1 time.Time, times ...time.Time) time.Time
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/MCIDvHNOGGb)</span></b>

 ```go
 package main
@@ -1615,7 +1615,7 @@ func main() {
 func Max(t1 time.Time, times ...time.Time) time.Time
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/9m6JMk1LB7-)</span></b>

 ```go
 package main
@@ -1645,7 +1645,7 @@ func main() {
 func MaxMin(t1 time.Time, times ...time.Time) (maxTime time.Time, minTime time.Time)
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/rbW51cDtM_2)</span></b>

 ```go
 package main
--- a/docs/api/packages/fileutil.md
+++ b/docs/api/packages/fileutil.md
@@ -1088,7 +1088,7 @@ func main() {
 func GetExeOrDllVersion(filePath string) (string, error)
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/iLRrDBhE38E)</span></b>

 ```go
 package main
--- a/docs/api/packages/mathutil.md
+++ b/docs/api/packages/mathutil.md
@@ -1178,7 +1178,7 @@ func main() {
 func Variance[T constraints.Float | constraints.Integer](numbers []T) float64
 ```

-<b>示例:<span style="float:right;display:inline-block;">[示例](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[示例](https://go.dev/play/p/uHuV4YgXf8F)</span></b>

 ```go
 package main
@@ -1211,7 +1211,7 @@ func main() {
 func StdDev[T constraints.Float | constraints.Integer](numbers []T) float64
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/FkNZDXvHD2l)</span></b>

 ```go
 package main
@@ -1222,8 +1222,8 @@ import (
 )

 func main() {
-    result1 := mathutil.T运行cRound(mathutil.StdDev([]int{1, 2, 3, 4, 5}), 2)
-    result2 := mathutil.T运行cRound(mathutil.StdDev([]float64{1.1, 2.2, 3.3, 4.4, 5.5}), 2)
+    result1 := mathutil.TruncRound(mathutil.StdDev([]int{1, 2, 3, 4, 5}), 2)
+    result2 := mathutil.TruncRound(mathutil.StdDev([]float64{1.1, 2.2, 3.3, 4.4, 5.5}), 2)

    fmt.Println(result1)
    fmt.Println(result2)
@@ -1244,7 +1244,7 @@ func main() {
 func Permutation(n, k uint) uint
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/MgobwH_FOxj)</span></b>

 ```go
 package main
@@ -1277,7 +1277,7 @@ func main() {
 func Combination(n, k uint) uint
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/ENFQRDQUFi9)</span></b>

 ```go
 package main
--- a/docs/api/packages/random.md
+++ b/docs/api/packages/random.md
@@ -534,7 +534,7 @@ func main() {
 func RandNumberOfLength(len int) int
 ```

-<b>实例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>实例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/oyZbuV7bu7b)</span></b>

 ```go
 package main
--- a/docs/api/packages/slice.md
+++ b/docs/api/packages/slice.md
@@ -44,6 +44,7 @@ import (
 -   [Every](#Every)
 -   [Equal](#Equal)
 -   [EqualWith](#EqualWith)
+-   [EqualUnordered](#EqualUnordered)
 -   [Filter](#Filter)
 -   [FilterConcurrent](#FilterConcurrent)
 -   [Find<sup>deprecated</sup>](#Find)
@@ -69,6 +70,7 @@ import (
 -   [FlatMap](#FlatMap)
 -   [Merge](#Merge)
 -   [Reverse](#Reverse)
+-   [ReverseCopy](#ReverseCopy)
 -   [Reduce<sup>deprecated</sup>](#Reduce)
 -   [ReduceConcurrent](#ReduceConcurrent)
 -   [ReduceBy](#ReduceBy)
@@ -77,6 +79,7 @@ import (
 -   [ReplaceAll](#ReplaceAll)
 -   [Repeat](#Repeat)
 -   [Shuffle](#Shuffle)
+-   [ShuffleCopy](#ShuffleCopy)
 -   [IsAscending](#IsAscending)
 -   [IsDescending](#IsDescending)
 -   [IsSorted](#IsSorted)
@@ -874,6 +877,37 @@ func main() {
 }
 ```

+### <span id="EqualUnordered">EqualUnordered</span>
+
+<p>检查两个切片是否相等，元素数量相同，值相等，不考虑元素顺序。</p>
+
+<b>函数签名:</b>
+
+```go
+func EqualUnordered[T comparable](slice1, slice2 []T) bool
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    result1 := slice.EqualUnordered([]int{1, 2, 3}, []int{3, 2, 1})
+    result2 := slice.EqualUnordered([]int{1, 2, 3}, []int{4, 5, 6})
+
+    fmt.Println(result1)
+    fmt.Println(result2)
+
+    // Output:
+    // true
+    // false
+}
+```
+
 ### <span id="Filter">Filter</span>

 <p>返回切片中通过predicate函数真值测试的所有元素</p>
@@ -1728,6 +1762,38 @@ func main() {
 }
 ```

+### <span id="ReverseCopy">ReverseCopy</span>
+
+<p>反转切片中的元素顺序, 不改变原slice。</p>
+
+<b>函数签名:</b>
+
+```go
+func ReverseCopy[T any](slice []T) []T
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    strs := []string{"a", "b", "c", "d"}
+
+    reversedStrs := slice.ReverseCopy(strs)
+
+    fmt.Println(reversedStrs)
+    fmt.Println(strs)
+
+    // Output:
+    // [d c b a]
+    // [a b c d]
+}
+```
+
 ### <span id="Reduce">Reduce</span>

 <p>将切片中的元素依次运行iteratee函数，返回运行结果。</p>
@@ -1962,7 +2028,7 @@ func main() {

 ### <span id="Shuffle">Shuffle</span>

-<p>随机打乱切片中的元素顺序</p>
+<p>随机打乱切片中的元素顺序。</p>

 <b>函数签名:</b>

@@ -1989,6 +2055,37 @@ func main() {
 }
 ```

+### <span id="ShuffleCopy">ShuffleCopy</span>
+
+<p>随机打乱切片中的元素顺序, 不改变原切片。</p>
+
+<b>函数签名:</b>
+
+```go
+func ShuffleCopy[T any](slice []T) []T
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    nums := []int{1, 2, 3, 4, 5}
+    result := slice.ShuffleCopy(nums)
+
+    fmt.Println(result)
+    fmt.Println(nums)
+
+    // Output:
+    // [3 1 5 4 2] (random order)
+    // [1 2 3 4 5]
+}
+```
+
 ### <span id="IsAscending">IsAscending</span>

 <p>检查切片元素是否按升序排列。</p>
@@ -2999,7 +3096,7 @@ func main() {
 func JoinFunc[T any](slice []T, sep string, transform func(T) T) string
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/55ib3SB5fM2)</span></b>

 ```go
 import (
@@ -3029,7 +3126,7 @@ func main() {
 func ConcatBy[T any](slice []T, sep T, connector func(T, T) T) T
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/6QcUpcY4UMW)</span></b>

 ```go
 import (
--- a/docs/api/packages/stream.md
+++ b/docs/api/packages/stream.md
@@ -951,7 +951,7 @@ func main() {
 func (s Stream[T]) IndexOf(target T, equal func(a, b T) bool) int
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/tBV5Nc-XDX2)</span></b>

 ```go
 import (
@@ -984,7 +984,7 @@ func main() {
 func (s Stream[T]) LastIndexOf(target T, equal func(a, b T) bool) int
 ```

-<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/CjeoNw2eac_G)</span></b>

 ```go
 import (
--- a/docs/api/packages/strutil.md
+++ b/docs/api/packages/strutil.md
@@ -69,6 +69,7 @@ import (
 -   [TemplateReplace](#TemplateReplace)
 -   [RegexMatchAllGroups](#RegexMatchAllGroups)
 -   [ExtractContent](#ExtractContent)
+-   [FindAllOccurrences](#FindAllOccurrences)


 <div STYLE="page-break-after: always;"></div>
@@ -1708,7 +1709,7 @@ func main() {
 func RegexMatchAllGroups(pattern, str string) [][]string
 ```

-<b>示例:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/JZiu0RXpgN-)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/JZiu0RXpgN-)</span></b>

 ```go
 import (
@@ -1741,7 +1742,7 @@ func main() {
 func ExtractContent(s, start, end string) []string
 ```

-<b>示例:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block;">[运行](https://go.dev/play/p/Ay9UIk7Rum9)</span></b>

 ```go
 import (
@@ -1759,4 +1760,32 @@ func main() {
    // Output:
    // [content1 content2 content1]
 }
+```
+
+### <span id="FindAllOccurrences">FindAllOccurrences</span>
+
+<p>返回子字符串在字符串中所有出现的位置。</p>
+
+<b>函数签名:</b>
+
+```go
+func FindAllOccurrences(str, substr string) []int
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/strutil"
+)
+
+func main() {
+    result := strutil.FindAllOccurrences("ababab", "ab")
+
+    fmt.Println(result)
+
+    // Output:
+    // [0 2 4]
+}
 ```
--- a/docs/api/packages/xerror.md
+++ b/docs/api/packages/xerror.md
@@ -509,7 +509,7 @@ func (tc *TryCatch) Finally(finallyFunc func(ctx context.Context)) *TryCatch
 func (tc *TryCatch) Do()
 ```

-<b>示例:<span style="float:right;display:inline-block">[运行](todo)</span></b>
+<b>示例:<span style="float:right;display:inline-block">[运行](https://go.dev/play/p/D5Mdb0mRj0P)</span></b>

 ```go
 package main
@@ -529,8 +529,6 @@ func main() {
        return errors.New("error in try block")
    }).Catch(func(ctx context.Context, err error) {
        calledCatch = true
-        // Error in try block at /path/xxx.go:{line_number} - Cause: error message
-        // fmt.Println(err.Error())
    }).Finally(func(ctx context.Context) {
        calledFinally = true
    }).Do()
--- a/docs/en/api/packages/convertor.md
+++ b/docs/en/api/packages/convertor.md
@@ -373,7 +373,7 @@ import (

 func main() {
    aMap := map[string]int{"a": 1, "b": 2, "c": 3}
-    result, err := ToJson(aMap)
+    result, err := convertor.ToJson(aMap)

    if err != nil {
        fmt.Printf("%v", err)
@@ -1123,7 +1123,7 @@ func main() {

 <p>Converts an integer of any supported type (int, int64, uint64, etc.) to *big.Int</p>

-<b>Signature:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Signature:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/X3itkCxwB_x)</span></b>

 ```go
 func ToBigInt[T any](v T) (*big.Int, error)
--- a/docs/en/api/packages/cryptor.md
+++ b/docs/en/api/packages/cryptor.md
@@ -1435,7 +1435,7 @@ func main() {
 func RsaEncrypt(data []byte, pubKeyFileName string) []byte
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/uef0q1fz53I)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/7_zo6mrx-eX)</span></b>

 ```go
 package main
@@ -1472,7 +1472,7 @@ func main() {
 func RsaDecrypt(data []byte, privateKeyFileName string) []byte
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/uef0q1fz53I)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/7_zo6mrx-eX)</span></b>

 ```go
 package main
@@ -1620,7 +1620,7 @@ func main() {
 func RsaSign(hash crypto.Hash, data []byte, privateKeyFileName string) ([]byte, error)
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/qhsbf8BJ6Mf)</span></b>

 ```go
 package main
@@ -1659,7 +1659,7 @@ func main() {
 func RsaVerifySign(hash crypto.Hash, data, signature []byte, pubKeyFileName string) error
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/qhsbf8BJ6Mf)</span></b>

 ```go
 package main
--- a/docs/en/api/packages/datetime.md
+++ b/docs/en/api/packages/datetime.md
@@ -1586,7 +1586,7 @@ func main() {
 func Min(t1 time.Time, times ...time.Time) time.Time
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/MCIDvHNOGGb)</span></b>

 ```go
 package main
@@ -1616,7 +1616,7 @@ func main() {
 func Max(t1 time.Time, times ...time.Time) time.Time
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/9m6JMk1LB7-)</span></b>

 ```go
 package main
@@ -1646,7 +1646,7 @@ func main() {
 func MaxMin(t1 time.Time, times ...time.Time) (maxTime time.Time, minTime time.Time)
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/rbW51cDtM_2)</span></b>

 ```go
 package main
--- a/docs/en/api/packages/fileutil.md
+++ b/docs/en/api/packages/fileutil.md
@@ -1087,7 +1087,7 @@ func main() {
 func GetExeOrDllVersion(filePath string) (string, error)
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/iLRrDBhE38E)</span></b>

 ```go
 package main
--- a/docs/en/api/packages/mathutil.md
+++ b/docs/en/api/packages/mathutil.md
@@ -1177,7 +1177,7 @@ func main() {
 func Variance[T constraints.Float | constraints.Integer](numbers []T) float64
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/uHuV4YgXf8F)</span></b>

 ```go
 package main
@@ -1210,7 +1210,7 @@ func main() {
 func StdDev[T constraints.Float | constraints.Integer](numbers []T) float64
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/FkNZDXvHD2l)</span></b>

 ```go
 package main
@@ -1243,7 +1243,7 @@ func main() {
 func Permutation(n, k uint) uint
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/MgobwH_FOxj)</span></b>

 ```go
 package main
@@ -1276,7 +1276,7 @@ func main() {
 func Combination(n, k uint) uint
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/ENFQRDQUFi9)</span></b>

 ```go
 package main
--- a/docs/en/api/packages/random.md
+++ b/docs/en/api/packages/random.md
@@ -536,7 +536,7 @@ func main() {
 func RandNumberOfLength(len int) int
 ```

-<b>Signature:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Signature:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/oyZbuV7bu7b)</span></b>

 ```go
 package main
--- a/docs/en/api/packages/slice.md
+++ b/docs/en/api/packages/slice.md
@@ -43,6 +43,7 @@ import (
 -   [DropRightWhile](#DropRightWhile)
 -   [Equal](#Equal)
 -   [EqualWith](#EqualWith)
+-   [EqualUnordered](#EqualUnordered)
 -   [Every](#Every)
 -   [Filter](#Filter)
 -   [FilterConcurrent](#FilterConcurrent)
@@ -69,6 +70,7 @@ import (
 -   [FlatMap](#FlatMap)
 -   [Merge](#Merge)
 -   [Reverse](#Reverse)
+-   [ReverseCopy](#ReverseCopy)
 -   [Reduce<sup>deprecated</sup>](#Reduce)
 -   [ReduceConcurrent](#ReduceConcurrent)
 -   [ReduceBy](#ReduceBy)
@@ -77,6 +79,7 @@ import (
 -   [ReplaceAll](#ReplaceAll)
 -   [Repeat](#Repeat)
 -   [Shuffle](#Shuffle)
+-   [ShuffleCopy](#ShuffleCopy)
 -   [IsAscending](#IsAscending)
 -   [IsDescending](#IsDescending)
 -   [IsSorted](#IsSorted)
@@ -839,6 +842,37 @@ func main() {
 }
 ```

+### <span id="EqualUnordered">EqualUnordered</span>
+
+<p>Checks if two slices are equal: the same length and all elements' value are equal (unordered).</p>
+
+<b>Signature:</b>
+
+```go
+func EqualUnordered[T comparable](slice1, slice2 []T) bool
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    result1 := slice.EqualUnordered([]int{1, 2, 3}, []int{3, 2, 1})
+    result2 := slice.EqualUnordered([]int{1, 2, 3}, []int{4, 5, 6})
+
+    fmt.Println(result1)
+    fmt.Println(result2)
+
+    // Output:
+    // true
+    // false
+}
+```
+
 ### <span id="Every">Every</span>

 <p>Return true if all of the values in the slice pass the predicate function.</p>
@@ -1724,6 +1758,38 @@ func main() {
 }
 ```

+### <span id="ReverseCopy">ReverseCopy</span>
+
+<p>Return a new slice of element order is reversed to the given slice.</p>
+
+<b>Signature:</b>
+
+```go
+func ReverseCopy[T any](slice []T) []T
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    strs := []string{"a", "b", "c", "d"}
+
+    reversedStrs := slice.ReverseCopy(strs)
+
+    fmt.Println(reversedStrs)
+    fmt.Println(strs)
+
+    // Output:
+    // [d c b a]
+    // [a b c d]
+}
+```
+
 ### <span id="Reduce">Reduce</span>

 <p>Reduce slice.</p>
@@ -1986,6 +2052,37 @@ func main() {
 }
 ```

+### <span id="ShuffleCopy">ShuffleCopy</span>
+
+<p>Return a new slice with elements shuffled.</p>
+
+<b>Signature:</b>
+
+```go
+func ShuffleCopy[T any](slice []T) []T
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/slice"
+)
+
+func main() {
+    nums := []int{1, 2, 3, 4, 5}
+    result := slice.ShuffleCopy(nums)
+
+    fmt.Println(result)
+    fmt.Println(nums)
+
+    // Output:
+    // [3 1 5 4 2] (random order)
+    // [1 2 3 4 5]
+}
+```
+
 ### <span id="IsAscending">IsAscending</span>

 <p>Checks if a slice is ascending order.</p>
@@ -2995,7 +3092,7 @@ func main() {
 func JoinFunc[T any](slice []T, sep string, transform func(T) T) string
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/55ib3SB5fM2)</span></b>

 ```go
 import (
@@ -3025,7 +3122,7 @@ func main() {
 func ConcatBy[T any](slice []T, sep T, connector func(T, T) T) T
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/6QcUpcY4UMW)</span></b>

 ```go
 import (
--- a/docs/en/api/packages/stream.md
+++ b/docs/en/api/packages/stream.md
@@ -950,7 +950,7 @@ func main() {
 func (s Stream[T]) IndexOf(target T, equal func(a, b T) bool) int
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/tBV5Nc-XDX2)</span></b>

 ```go
 import (
@@ -983,7 +983,7 @@ func main() {
 func (s Stream[T]) LastIndexOf(target T, equal func(a, b T) bool) int
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/CjeoNw2eac_G)</span></b>

 ```go
 import (
--- a/docs/en/api/packages/strutil.md
+++ b/docs/en/api/packages/strutil.md
@@ -68,7 +68,8 @@ import (
 -   [Rotate](#Rotate)
 -   [TemplateReplace](#TemplateReplace)
 -   [RegexMatchAllGroups](#RegexMatchAllGroups)
-   [ExtractContent](#RegexMatchAllGroups)
+-   [ExtractContent](#ExtractContent)
+-   [FindAllOccurrences](#FindAllOccurrences)


 <div STYLE="page-break-after: always;"></div>
@@ -1743,7 +1744,7 @@ func main() {
 func ExtractContent(s, start, end string) []string
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/Ay9UIk7Rum9)</span></b>

 ```go
 import (
@@ -1761,4 +1762,32 @@ func main() {
    // Output:
    // [content1 content2 content1]
 }
+```
+
+### <span id="FindAllOccurrences">FindAllOccurrences</span>
+
+<p>Returns the positions of all occurrences of a substring in a string.</p>
+
+<b>Signature:</b>
+
+```go
+func FindAllOccurrences(str, substr string) []int
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/strutil"
+)
+
+func main() {
+    result := strutil.FindAllOccurrences("ababab", "ab")
+
+    fmt.Println(result)
+
+    // Output:
+    // [0 2 4]
+}
 ```
--- a/docs/en/api/packages/xerror.md
+++ b/docs/en/api/packages/xerror.md
@@ -507,7 +507,7 @@ func (tc *TryCatch) Finally(finallyFunc func(ctx context.Context)) *TryCatch
 func (tc *TryCatch) Do()
 ```

-<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+<b>Example:<span style="float:right;display:inline-block;">[Run](https://go.dev/play/p/D5Mdb0mRj0P)</span></b>

 ```go
 package main
--- a/docs/en/guide/getting_started.md
+++ b/docs/en/guide/getting_started.md
@@ -10,7 +10,7 @@ outline: deep
 go get github.com/duke-git/lancet/v2 // will install latest version of v2.x.x
 ```

-2. <b>For users who use version below go1.18, you should install v1.x.x. The latest of v1.x.x is v1.4.5. </b>
+2. <b>For users who use version below go1.18, you should install v1.x.x. The latest of v1.x.x is v1.4.6. </b>

 ```go
 go get github.com/duke-git/lancet // below go1.18, install latest version of v1.x.x
--- a/docs/guide/getting_started.md
+++ b/docs/guide/getting_started.md
@@ -10,7 +10,7 @@ outline: deep
 go get github.com/duke-git/lancet/v2 // will install latest version of v2.x.x
 ```

-2. <b>使用 go1.18 以下版本的用户，必须安装 v1.x.x。目前最新的 v1 版本是 v1.4.5。</b>
+2. <b>使用 go1.18 以下版本的用户，必须安装 v1.x.x。目前最新的 v1 版本是 v1.4.6。</b>

 ```go
 go get github.com/duke-git/lancet // below go1.18, install latest version of v1.x.x
--- a/eventbus/eventbus.go
+++ b/eventbus/eventbus.go
@@ -0,0 +1,185 @@
+// Copyright 2025 dudaodong@gmail.com. All rights reserved.
+// Use of this source code is governed by MIT license
+
+// Package eventbus implements a simple event bus.
+package eventbus
+
+import (
+	"fmt"
+	"sort"
+	"sync"
+)
+
+// Event is the struct that is passed to the event listener, now it directly uses the generic Payload type.
+type Event[T any] struct {
+	Topic   string
+	Payload T
+}
+
+// EventBus is the struct that holds the listeners and the error handler.
+type EventBus[T any] struct {
+	// listeners    map[string][]*EventListener[T]
+	listeners    sync.Map
+	mu           sync.RWMutex
+	errorHandler func(err error)
+}
+
+// EventListener is the struct that holds the listener function and its priority.
+type EventListener[T any] struct {
+	priority int
+	listener func(eventData T)
+	async    bool
+	filter   func(eventData T) bool
+}
+
+// NewEventBus creates a new EventBus.
+func NewEventBus[T any]() *EventBus[T] {
+	return &EventBus[T]{
+		listeners: sync.Map{},
+	}
+}
+
+// Subscribe subscribes to an event with a specific event topic and listener function.
+func (eb *EventBus[T]) Subscribe(topic string, listener func(eventData T), async bool, priority int, filter func(eventData T) bool) {
+	eb.mu.Lock()
+	defer eb.mu.Unlock()
+
+	el := &EventListener[T]{
+		priority: priority,
+		listener: listener,
+		async:    async,
+		filter:   filter,
+	}
+
+	listenersInterface, _ := eb.listeners.LoadOrStore(topic, []*EventListener[T]{})
+	listeners := listenersInterface.([]*EventListener[T])
+
+	listeners = append(listeners, el)
+	sort.Slice(listeners, func(i, j int) bool {
+		return listeners[i].priority > listeners[j].priority
+	})
+
+	eb.listeners.Store(topic, listeners)
+}
+
+// Unsubscribe unsubscribes from an event with a specific event topic and listener function.
+func (eb *EventBus[T]) Unsubscribe(topic string, listener func(eventData T)) {
+	eb.mu.Lock()
+	defer eb.mu.Unlock()
+
+	listenersInterface, ok := eb.listeners.Load(topic)
+	if !ok {
+		return
+	}
+
+	listeners := listenersInterface.([]*EventListener[T])
+	listenerPtr := fmt.Sprintf("%p", listener)
+
+	var updatedListeners []*EventListener[T]
+	for _, l := range listeners {
+		if fmt.Sprintf("%p", l.listener) != listenerPtr {
+			updatedListeners = append(updatedListeners, l)
+		}
+	}
+
+	eb.listeners.Store(topic, updatedListeners)
+}
+
+// Publish publishes an event with a specific event topic and data payload.
+func (eb *EventBus[T]) Publish(event Event[T]) {
+	eb.mu.RLock()
+	defer eb.mu.RUnlock()
+
+	listenersInterface, exists := eb.listeners.Load(event.Topic)
+	if !exists {
+		return
+	}
+
+	listeners := listenersInterface.([]*EventListener[T])
+
+	for _, listener := range listeners {
+		if listener.filter != nil && !listener.filter(event.Payload) {
+			continue
+		}
+
+		if listener.async {
+			go eb.publishToListener(listener, event)
+		} else {
+			eb.publishToListener(listener, event)
+		}
+	}
+}
+
+func (eb *EventBus[T]) publishToListener(listener *EventListener[T], event Event[T]) {
+	defer func() {
+		if r := recover(); r != nil && eb.errorHandler != nil {
+			eb.errorHandler(fmt.Errorf("%v", r))
+		}
+	}()
+
+	listener.listener(event.Payload)
+}
+
+// SetErrorHandler sets the error handler function.
+func (eb *EventBus[T]) SetErrorHandler(handler func(err error)) {
+	eb.errorHandler = handler
+}
+
+// ClearListeners clears all the listeners.
+func (eb *EventBus[T]) ClearListeners() {
+	eb.mu.Lock()
+	defer eb.mu.Unlock()
+
+	eb.listeners = sync.Map{}
+}
+
+// ClearListenersByTopic clears all the listeners by topic.
+func (eb *EventBus[T]) ClearListenersByTopic(topic string) {
+	eb.mu.Lock()
+	defer eb.mu.Unlock()
+
+	eb.listeners.Delete(topic)
+}
+
+// GetListenersCount returns the number of listeners for a specific event topic.
+func (eb *EventBus[T]) GetListenersCount(topic string) int {
+	eb.mu.RLock()
+	defer eb.mu.RUnlock()
+
+	listenersInterface, ok := eb.listeners.Load(topic)
+	if !ok {
+		return 0
+	}
+
+	listeners := listenersInterface.([]*EventListener[T])
+	return len(listeners)
+}
+
+// GetAllListenersCount returns the total number of listeners.
+func (eb *EventBus[T]) GetAllListenersCount() int {
+	eb.mu.RLock()
+	defer eb.mu.RUnlock()
+
+	count := 0
+	eb.listeners.Range(func(key, value interface{}) bool {
+		count += len(value.([]*EventListener[T]))
+		return true
+	})
+
+	return count
+}
+
+// GetEvents returns all the events topics.
+func (eb *EventBus[T]) GetEvents() []string {
+	eb.mu.RLock()
+	defer eb.mu.RUnlock()
+
+	var events []string
+
+	eb.listeners.Range(func(key, value interface{}) bool {
+		events = append(events, key.(string))
+		return true
+	})
+
+	return events
+}
--- a/eventbus/eventbus_test.go
+++ b/eventbus/eventbus_test.go
@@ -0,0 +1,220 @@
+package eventbus
+
+import (
+	"sync"
+	"testing"
+	"time"
+
+	"github.com/duke-git/lancet/v2/internal"
+)
+
+func TestEventBus_Subscribe(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_Subscribe")
+
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {
+		assert.Equal(1, eventData)
+	}, false, 0, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+}
+
+func TestEventBus_Unsubscribe(t *testing.T) {
+
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_Unsubscribe")
+
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	eb.Subscribe("event1", listener, false, 0, nil)
+	eb.Unsubscribe("event1", listener)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	assert.Equal(0, receivedData)
+}
+
+func TestEventBus_Subscribe_WithFilter(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_Subscribe_WithFilter")
+
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	filter := func(eventData int) bool {
+		return eventData == 1
+	}
+
+	eb.Subscribe("event1", listener, false, 0, filter)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+	eb.Publish(Event[int]{Topic: "event1", Payload: 2})
+
+	assert.Equal(1, receivedData)
+}
+
+func TestEventBus_Subscribe_WithPriority(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_Subscribe_WithPriority")
+
+	eb := NewEventBus[int]()
+
+	var receivedData []int
+	listener1 := func(eventData int) {
+		receivedData = append(receivedData, 1)
+	}
+
+	listener2 := func(eventData int) {
+		receivedData = append(receivedData, 2)
+	}
+
+	eb.Subscribe("event1", listener1, false, 1, nil)
+	eb.Subscribe("event1", listener2, false, 2, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	assert.Equal([]int{2, 1}, receivedData)
+}
+
+func TestEventBus_Subscribe_Async(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_Subscribe_Async")
+
+	eb := NewEventBus[string]()
+
+	var wg sync.WaitGroup
+	wg.Add(1)
+
+	eb.Subscribe("event1", func(eventData string) {
+		time.Sleep(100 * time.Millisecond)
+		assert.Equal("hello", eventData)
+		wg.Done()
+	}, true, 1, nil)
+
+	eb.Publish(Event[string]{Topic: "event1", Payload: "hello"})
+
+	wg.Wait()
+}
+
+func TestEventBus_ErrorHandler(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_ErrorHandler")
+
+	eb := NewEventBus[string]()
+
+	eb.SetErrorHandler(func(err error) {
+		assert.Equal("error", err.Error())
+	})
+
+	eb.Subscribe("event1", func(eventData string) {
+		panic("error")
+	}, false, 0, nil)
+
+	eb.Publish(Event[string]{Topic: "event1", Payload: "hello"})
+}
+
+func TestEventBus_ClearListeners(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_ClearListeners")
+
+	eb := NewEventBus[int]()
+
+	receivedData1 := 0
+	receivedData2 := 0
+
+	eb.Subscribe("event1", func(eventData int) {
+		receivedData1 = eventData
+	}, false, 0, nil)
+
+	eb.Subscribe("event2", func(eventData int) {
+		receivedData2 = eventData
+	}, false, 0, nil)
+
+	eb.ClearListeners()
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+	eb.Publish(Event[int]{Topic: "event1", Payload: 2})
+
+	assert.Equal(0, receivedData1)
+	assert.Equal(0, receivedData2)
+}
+
+func TestEventBus_ClearListenersByTopic(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_ClearListenersByTopic")
+
+	eb := NewEventBus[int]()
+
+	receivedData1 := 0
+	receivedData2 := 0
+
+	eb.Subscribe("event1", func(eventData int) {
+		receivedData1 = eventData
+	}, false, 0, nil)
+
+	eb.Subscribe("event2", func(eventData int) {
+		receivedData2 = eventData
+	}, false, 0, nil)
+
+	eb.ClearListenersByTopic("event1")
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+	eb.Publish(Event[int]{Topic: "event2", Payload: 2})
+
+	assert.Equal(0, receivedData1)
+	assert.Equal(2, receivedData2)
+}
+
+func TestEventBus_GetListenersCount(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_GetListenersCount")
+
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+	assert.Equal(2, eb.GetListenersCount("event1"))
+	assert.Equal(1, eb.GetListenersCount("event2"))
+}
+
+func TestEventBus_GetAllListenersCount(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_GetAllListenersCount")
+
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+	assert.Equal(3, eb.GetAllListenersCount())
+}
+
+func TestEventBus_GetEvents(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestEventBus_GetEvents")
+
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+	events := eb.GetEvents()
+
+	assert.Equal(2, len(events))
+	assert.Equal("event1", events[0])
+	assert.Equal("event2", events[1])
+}
--- a/fileutil/file.go
+++ b/fileutil/file.go
@@ -25,6 +25,8 @@ import (
 	"sync"

 	"github.com/duke-git/lancet/v2/validator"
+	"golang.org/x/text/encoding/simplifiedchinese"
+	"golang.org/x/text/transform"
 )

 // FileReader is a reader supporting offset seeking and reading one
@@ -422,8 +424,15 @@ func UnZip(zipFile string, destPath string) error {
 	defer zipReader.Close()

 	for _, f := range zipReader.File {
+		decodeName := f.Name
+		if f.Flags == 0 {
+			i := bytes.NewReader([]byte(f.Name))
+			decoder := transform.NewReader(i, simplifiedchinese.GB18030.NewDecoder())
+			content, _ := io.ReadAll(decoder)
+			decodeName = string(content)
+		}
 		// issue#62: fix ZipSlip bug
-		path, err := safeFilepathJoin(destPath, f.Name)
+		path, err := safeFilepathJoin(destPath, decodeName)
 		if err != nil {
 			return err
 		}
--- a/fileutil/file_windows.go
+++ b/fileutil/file_windows.go
@@ -26,7 +26,7 @@ type tagVS_FIXEDFILEINFO struct {
 }

 // GetExeOrDllVersion get the version of exe or dll file on windows.
-// Play: todo
+// Play: https://go.dev/play/p/iLRrDBhE38E
 func GetExeOrDllVersion(filePath string) (string, error) {
 	// 加载系统dll
 	versionDLL := syscall.NewLazyDLL("version.dll")
--- a/mathutil/mathutil.go
+++ b/mathutil/mathutil.go
@@ -145,10 +145,14 @@ func CeilToString[T constraints.Float | constraints.Integer](x T, n int) string

 // Max return max value of numbers.
 // Play: https://go.dev/play/p/cN8DHI0rTkH
-func Max[T constraints.Integer | constraints.Float](numbers ...T) T {
-	max := numbers[0]
+func Max[T constraints.Ordered](items ...T) T {
+	if len(items) < 1 {
+		panic("mathutil.Max: empty list")
+	}

-	for _, v := range numbers {
+	max := items[0]
+
+	for _, v := range items {
 		if max < v {
 			max = v
 		}
@@ -181,10 +185,14 @@ func MaxBy[T any](slice []T, comparator func(T, T) bool) T {

 // Min return min value of numbers.
 // Play: https://go.dev/play/p/21BER_mlGUj
-func Min[T constraints.Integer | constraints.Float](numbers ...T) T {
-	min := numbers[0]
+func Min[T constraints.Ordered](items ...T) T {
+	if len(items) < 1 {
+		panic("mathutil.min: empty list")
+	}

-	for _, v := range numbers {
+	min := items[0]
+
+	for _, v := range items {
 		if min > v {
 			min = v
 		}
@@ -400,7 +408,7 @@ func Div[T constraints.Float | constraints.Integer](x T, y T) float64 {
 }

 // Variance returns the variance of numbers.
-// Play: todo
+// Play: https://go.dev/play/p/uHuV4YgXf8F
 func Variance[T constraints.Float | constraints.Integer](numbers []T) float64 {
 	n := len(numbers)
 	if n == 0 {
@@ -418,13 +426,13 @@ func Variance[T constraints.Float | constraints.Integer](numbers []T) float64 {
 }

 // StdDev returns the standard deviation of numbers.
-// Play: todo
+// Play: https://go.dev/play/p/FkNZDXvHD2l
 func StdDev[T constraints.Float | constraints.Integer](numbers []T) float64 {
 	return math.Sqrt(Variance(numbers))
 }

 // Permutation calculate P(n, k).
-// Play: todo
+// Play: https://go.dev/play/p/MgobwH_FOxj
 func Permutation(n, k uint) uint {
 	if n < k {
 		return 0
@@ -437,7 +445,7 @@ func Permutation(n, k uint) uint {
 }

 // Combination calculate C(n, k).
-// Play: todo
+// Play: https://go.dev/play/p/ENFQRDQUFi9
 func Combination(n, k uint) uint {
 	if n < k {
 		return 0
--- a/mathutil/mathutil_test.go
+++ b/mathutil/mathutil_test.go
@@ -178,6 +178,7 @@ func TestMax(t *testing.T) {
 	assert.Equal(0, Max(0, 0))
 	assert.Equal(3, Max(1, 2, 3))
 	assert.Equal(1.4, Max(1.2, 1.4, 1.1, 1.4))
+	assert.Equal("abc", Max("a", "ab", "abc"))

 	type Integer int
 	assert.Equal(Integer(1), Max(Integer(1), Integer(0)))
@@ -212,6 +213,8 @@ func TestMin(t *testing.T) {
 	assert.Equal(0, Min(0, 0))
 	assert.Equal(1, Min(1, 2, 3))
 	assert.Equal(1.1, Min(1.2, 1.4, 1.1, 1.4))
+
+	assert.Equal("a", Min("a", "ab", "abc"))
 }

 func TestMinBy(t *testing.T) {
--- a/random/random.go
+++ b/random/random.go
@@ -126,12 +126,24 @@ func RandFloat(min, max float64, precision int) float64 {

 	n := rand.Float64()*(max-min) + min

-	return mathutil.RoundToFloat(n, precision)
+	return mathutil.FloorToFloat(n, precision)
 }

 // RandFloats generate a slice of random float64 numbers of length that do not repeat.
 // Play: https://go.dev/play/p/I3yndUQ-rhh
 func RandFloats(length int, min, max float64, precision int) []float64 {
+	if max < min {
+		min, max = max, min
+	}
+
+	maxLength := int((max - min) * math.Pow10(precision))
+	if maxLength == 0 {
+		maxLength = 1
+	}
+	if length > maxLength {
+		length = maxLength
+	}
+
 	nums := make([]float64, length)
 	used := make(map[float64]struct{}, length)
 	for i := 0; i < length; {
@@ -335,7 +347,7 @@ func UUIdV4() (string, error) {
 }

 // RandNumberOfLength 生成一个长度为len的随机数
-// Play: todo
+// Play: https://go.dev/play/p/oyZbuV7bu7b
 func RandNumberOfLength(len int) int {
 	m := int(math.Pow10(len) - 1)
 	i := int(math.Pow10(len - 1))
--- a/random/random_test.go
+++ b/random/random_test.go
@@ -197,6 +197,14 @@ func TestRandFloats(t *testing.T) {
 	}

 	assert.Equal(len(numbers), 5)
+
+	numbers2 := RandFloats(10, 3.14, 3.2, 2)
+	for _, n := range numbers2 {
+		assert.GreaterOrEqual(n, 3.14)
+		assert.Less(n, 3.2)
+	}
+
+	assert.Equal(len(numbers2), 6)
 }

 func TestRandIntSlice(t *testing.T) {
--- a/slice/slice.go
+++ b/slice/slice.go
@@ -220,6 +220,28 @@ func EqualWith[T, U any](slice1 []T, slice2 []U, comparator func(T, U) bool) boo
 	return true
 }

+// EqualUnordered checks if two slices are equal: the same length and all elements' value are equal (unordered).
+// Play: todo
+func EqualUnordered[T comparable](slice1, slice2 []T) bool {
+	if len(slice1) != len(slice2) {
+		return false
+	}
+
+	seen := make(map[T]int)
+	for _, v := range slice1 {
+		seen[v]++
+	}
+
+	for _, v := range slice2 {
+		if seen[v] == 0 {
+			return false
+		}
+		seen[v]--
+	}
+
+	return true
+}
+
 // Every return true if all of the values in the slice pass the predicate function.
 // Play: https://go.dev/play/p/R8U6Sl-j8cD
 func Every[T any](slice []T, predicate func(index int, item T) bool) bool {
@@ -980,7 +1002,19 @@ func Reverse[T any](slice []T) {
 	}
 }

-// Shuffle the slice.
+// ReverseCopy return a new slice of element order is reversed to the given slice.
+// Play: todo
+func ReverseCopy[T any](slice []T) []T {
+	result := make([]T, len(slice))
+
+	for i, j := 0, len(slice)-1; i < len(slice); i, j = i+1, j-1 {
+		result[i] = slice[j]
+	}
+
+	return result
+}
+
+// Shuffle return a new slice with elements shuffled.
 // Play: https://go.dev/play/p/YHvhnWGU3Ge
 func Shuffle[T any](slice []T) []T {
 	rand.Seed(time.Now().UnixNano())
@@ -992,6 +1026,20 @@ func Shuffle[T any](slice []T) []T {
 	return slice
 }

+// ShuffleCopy return a new slice with elements shuffled.
+// Play: todo
+func ShuffleCopy[T any](slice []T) []T {
+	result := make([]T, len(slice))
+	copy(result, slice)
+
+	rand.Seed(time.Now().UnixNano())
+	rand.Shuffle(len(result), func(i, j int) {
+		result[i], result[j] = result[j], result[i]
+	})
+
+	return result
+}
+
 // IsAscending checks if a slice is ascending order.
 // Play: https://go.dev/play/p/9CtsFjet4SH
 func IsAscending[T constraints.Ordered](slice []T) bool {
@@ -1415,7 +1463,7 @@ func Frequency[T comparable](slice []T) map[T]int {
 }

 // JoinFunc joins the slice elements into a single string with the given separator.
-// Play: todo
+// Play: https://go.dev/play/p/55ib3SB5fM2
 func JoinFunc[T any](slice []T, sep string, transform func(T) T) string {
 	var buf strings.Builder
 	for i, v := range slice {
@@ -1428,7 +1476,7 @@ func JoinFunc[T any](slice []T, sep string, transform func(T) T) string {
 }

 // ConcatBy concats the elements of a slice into a single value using the provided separator and connector function.
-// Play: todo
+// Play: https://go.dev/play/p/6QcUpcY4UMW
 func ConcatBy[T any](slice []T, sep T, connector func(T, T) T) T {
 	var result T

--- a/slice/slice_example_test.go
+++ b/slice/slice_example_test.go
@@ -937,6 +937,41 @@ func ExampleReverse() {
 	// [d c b a]
 }

+func ExampleReverseCopy() {
+	strs := []string{"a", "b", "c", "d"}
+
+	reversedStrs := ReverseCopy(strs)
+
+	fmt.Println(reversedStrs)
+	fmt.Println(strs)
+
+	// Output:
+	// [d c b a]
+	// [a b c d]
+}
+
+func ExampleShuffle() {
+	strs := []string{"a", "b", "c", "d"}
+	Shuffle(strs)
+
+	fmt.Println(len(strs))
+
+	// Output:
+	// 4
+}
+
+func ExampleShuffleCopy() {
+	strs := []string{"a", "b", "c", "d"}
+	shuffledStrs := ShuffleCopy(strs)
+
+	fmt.Println(len(shuffledStrs))
+	fmt.Println(strs)
+
+	// Output:
+	// 4
+	// [a b c d]
+}
+
 func ExampleIsAscending() {

 	result1 := IsAscending([]int{1, 2, 3, 4, 5})
@@ -1300,3 +1335,15 @@ func ExampleConcatBy() {
 	// Alice | Bob | Charlie
 	// 90
 }
+
+func ExampleEqualUnordered() {
+	result1 := EqualUnordered([]int{1, 2, 3}, []int{3, 2, 1})
+	result2 := EqualUnordered([]int{1, 2, 3}, []int{4, 5, 6})
+
+	fmt.Println(result1)
+	fmt.Println(result2)
+
+	// Output:
+	// true
+	// false
+}
--- a/slice/slice_test.go
+++ b/slice/slice_test.go
@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"math"
 	"reflect"
+	"sort"
 	"strconv"
 	"strings"
 	"sync"
@@ -1114,6 +1115,17 @@ func TestReverse(t *testing.T) {
 	assert.Equal([]string{"e", "d", "c", "b", "a"}, s2)
 }

+func TestReverseCopy(t *testing.T) {
+	t.Parallel()
+	assert := internal.NewAssert(t, "TestReverseCopy")
+
+	numbers := []int{1, 2, 3, 4, 5}
+	reversedNumbers := ReverseCopy(numbers)
+
+	assert.Equal([]int{5, 4, 3, 2, 1}, reversedNumbers)
+	assert.Equal([]int{1, 2, 3, 4, 5}, numbers)
+}
+
 func TestDifference(t *testing.T) {
 	t.Parallel()

@@ -1329,6 +1341,18 @@ func TestShuffle(t *testing.T) {
 	assert.Equal(5, len(result))
 }

+func TestShuffleCopy(t *testing.T) {
+	t.Parallel()
+
+	assert := internal.NewAssert(t, "TestShuffleCopy")
+
+	numbers := []int{1, 2, 3, 4, 5}
+	result := ShuffleCopy(numbers)
+
+	assert.Equal(5, len(result))
+	assert.Equal([]int{1, 2, 3, 4, 5}, numbers)
+}
+
 func TestIndexOf(t *testing.T) {
 	t.Parallel()

@@ -1794,6 +1818,8 @@ func TestFilterConcurrent(t *testing.T) {
 		nums := []int{1, 2, 3, 4, 5, 6}
 		expected := []int{4, 5, 6}
 		actual := FilterConcurrent(nums, func(_, n int) bool { return n > 3 }, 4)
+		sort.Ints(actual)
+		sort.Ints(expected)
 		assert.Equal(expected, actual)
 	})
 }
@@ -1926,3 +1952,25 @@ func TestConcatBy(t *testing.T) {
 		assert.Equal(90, result.Age)
 	})
 }
+
+func TestEqualUnordered(t *testing.T) {
+	t.Parallel()
+
+	assert := internal.NewAssert(t, "TestEqualUnordered")
+
+	tests := []struct {
+		slice1, slice2 []int
+		expected       bool
+	}{
+		{[]int{}, []int{}, true},
+		{[]int{1, 2, 3}, []int{1, 2, 3}, true},
+		{[]int{1, 2, 3}, []int{3, 2, 1}, true},
+		{[]int{1, 2, 3}, []int{1, 2, 3, 4}, false},
+		{[]int{1, 2, 3}, []int{1, 2}, false},
+		{[]int{1, 2, 3}, []int{1, 2, 4}, false},
+	}
+
+	for _, test := range tests {
+		assert.Equal(test.expected, EqualUnordered(test.slice1, test.slice2))
+	}
+}
--- a/stream/stream.go
+++ b/stream/stream.go
@@ -130,7 +130,6 @@ func (s Stream[T]) Distinct() Stream[T] {
 	distinct := map[string]bool{}

 	for _, v := range s.source {
-		// todo: performance issue
 		k := hashKey(v)
 		if _, ok := distinct[k]; !ok {
 			distinct[k] = true
@@ -395,6 +394,7 @@ func (s Stream[T]) Min(less func(a, b T) bool) (T, bool) {
 }

 // IndexOf returns the index of the first occurrence of the specified element in this stream, or -1 if this stream does not contain the element.
+// Play: https://go.dev/play/p/tBV5Nc-XDX2
 func (s Stream[T]) IndexOf(target T, equal func(a, b T) bool) int {
 	for i, v := range s.source {
 		if equal(v, target) {
@@ -405,6 +405,7 @@ func (s Stream[T]) IndexOf(target T, equal func(a, b T) bool) int {
 }

 // LastIndexOf returns the index of the last occurrence of the specified element in this stream, or -1 if this stream does not contain the element.
+// Play: https://go.dev/play/p/CjeoNw2eac_G
 func (s Stream[T]) LastIndexOf(target T, equal func(a, b T) bool) int {
 	for i := len(s.source) - 1; i >= 0; i-- {
 		if equal(s.source[i], target) {
--- a/strutil/string.go
+++ b/strutil/string.go
@@ -737,15 +737,15 @@ func RegexMatchAllGroups(pattern, str string) [][]string {
 }

 // ExtractContent extracts the content between the start and end strings in the source string.
-// Play: todo
-func ExtractContent(s, start, end string) []string {
+// Play: https://go.dev/play/p/Ay9UIk7Rum9
+func ExtractContent(str, start, end string) []string {
 	result := []string{}

 	for {
-		if _, after, ok := strings.Cut(s, start); ok {
+		if _, after, ok := strings.Cut(str, start); ok {
 			if before, _, ok := strings.Cut(after, end); ok {
 				result = append(result, before)
-				s = after
+				str = after
 			} else {
 				break
 			}
@@ -756,3 +756,20 @@ func ExtractContent(s, start, end string) []string {

 	return result
 }
+
+// FindAllOccurrences returns the positions of all occurrences of a substring in a string.
+// Play: todo
+func FindAllOccurrences(str, substr string) []int {
+	var positions []int
+
+	for i := 0; i < len(str); {
+		index := strings.Index(str[i:], substr)
+		if index == -1 {
+			break
+		}
+		positions = append(positions, i+index)
+		i += index + 1
+	}
+
+	return positions
+}
--- a/strutil/string_example_test.go
+++ b/strutil/string_example_test.go
@@ -763,5 +763,13 @@ func ExampleExtractContent() {

 	// Output:
 	// [content1 content2 content1]
-
+}
+
+func ExampleFindAllOccurrences() {
+	result := FindAllOccurrences("ababab", "ab")
+
+	fmt.Println(result)
+
+	// Output:
+	// [0 2 4]
 }
--- a/strutil/string_test.go
+++ b/strutil/string_test.go
@@ -937,3 +937,32 @@ func TestExtractContent(t *testing.T) {
 		})
 	}
 }
+
+func TestFindAllOccurrences(t *testing.T) {
+	t.Parallel()
+
+	assert := internal.NewAssert(t, "TestFindAllOccurrences")
+
+	var empty []int
+	tests := []struct {
+		input    string
+		substr   string
+		expected []int
+	}{
+		{"", "", empty},
+		{"", "a", empty},
+		{"a", "", []int{0}},
+		{"a", "a", []int{0}},
+		{"aa", "a", []int{0, 1}},
+		{"ababab", "ab", []int{0, 2, 4}},
+		{"ababab", "ba", []int{1, 3}},
+		{"ababab", "c", empty},
+		{"ababab", "ababab", []int{0}},
+		{"ababab", "abababc", empty},
+		{"ababab", "abababa", empty},
+	}
+
+	for _, tt := range tests {
+		assert.Equal(tt.expected, FindAllOccurrences(tt.input, tt.substr))
+	}
+}
Author	SHA1	Message	Date
dudaodong	db479ef1bc	fix: fix issue #292	2025-02-14 17:35:48 +08:00
dudaodong	df8121fbbd	Merge branch 'rc' into v2	2025-02-14 17:13:11 +08:00
dudaodong	0e7297cb97	feat: add ShuffleCopy	2025-02-14 16:33:22 +08:00
dudaodong	2e619e48a3	feat: add ReverseCopy	2025-02-14 16:23:46 +08:00
残念	3069acba4a	Merge pull request #293 from YoghurtFree/fix_slice_test fix(slice_test) , should not assume the order of the slice	2025-02-09 23:10:28 +08:00
jialulu	fc43138a0e	fix: fix slice_test.go ,We should not assume the order of the slice when using multithreads，sort them before compare	2025-02-09 22:23:35 +08:00
残念	1e56e9964c	Merge pull request #291 from guanhonly/feature/compatible-with-pointer-in-ToString compatible with pointer in convert.ToString	2025-01-30 22:26:34 +08:00
guanhongli	f861e18bc3	compatible with pointer in convert.ToString	2025-01-26 12:04:55 +08:00
Tuuuuuuuuu	e27df00fa8	make Bridge not block in the first stream that not closed (#288 ) * not block in the first channel * make Bridge not block in the first stream that not closed * Bridge with test	2025-01-14 16:19:45 +08:00
dudaodong	23e61f1acf	update pem file	2025-01-14 15:58:58 +08:00
dudaodong	cb308f628c	feat: add eventbus	2025-01-14 15:57:43 +08:00
dudaodong	7653afa919	feat: add FindAllOccurrences	2025-01-10 14:03:45 +08:00
dudaodong	a0d97cf38e	Merge branch 'rc' into v2	2024-12-25 16:13:04 +08:00
残念	1f6bab467c	Merge pull request #282 from Yurunsoft/fix-RandFloats fix the bug of random.RandFloats() infinite loop and the result of random.RandFloat() sometimes equals to max.	2024-12-25 15:14:17 +08:00
Yurun	2e5b9bc200	fix: fix the bug of random.RandFloats() infinite loop and the result of random.RandFloat() sometimes equals to max.	2024-12-25 14:13:11 +08:00
dudaodong	ab89f0aee1	feat: add EqualUnordered	2024-12-19 19:36:17 +08:00
tangke	1f64e02df4	fix(fileutil): unzip Chinese garbled code during decompression (#279 ) 解压时出现中文乱码	2024-12-19 19:06:27 +08:00
dudaodong	d4b425e39c	doc: fix doc error	2024-12-09 09:52:40 +08:00
dudaodong	a1652c7523	doc: update v1 latest version	2024-12-04 19:13:23 +08:00
dudaodong	ecafed511c	doc: add play ground demo for v2.3.4	2024-12-04 14:25:51 +08:00