v0.0.26

syncext/atomic.go

@@ -1,4 +1,4 @@
-package dataext
+package syncext
 
 import (
 	"context"
@@ -56,6 +56,12 @@ func (a *AtomicBool) Wait(waitFor bool) {
 	}
 }
 
+func (a *AtomicBool) WaitWithTimeout(timeout time.Duration, waitFor bool) error {
+	ctx, cancel := context.WithTimeout(context.Background(), timeout)
+	defer cancel()
+	return a.WaitWithContext(ctx, waitFor)
+}
+
 func (a *AtomicBool) WaitWithContext(ctx context.Context, waitFor bool) error {
 	if err := ctx.Err(); err != nil {
 		return err

syncext/channel.go

@@ -1,4 +1,4 @@
-package dataext
+package syncext
 
 import "time"
 

syncext/channel_test.go

@@ -1,4 +1,4 @@
-package dataext
+package syncext
 
 import (
 	"testing"