Split Selector into its own file

Author: cschleiden

workflow/select.go

@@ -0,0 +1,33 @@
+package workflow
+
+import "github.com/cschleiden/go-workflows/internal/sync"
+
+type SelectCase = sync.SelectCase
+
+// Select is the workflow-save equivalent of the select statement.
+func Select(ctx Context, cases ...SelectCase) {
+	sync.Select(ctx, cases...)
+}
+
+// Await calls the provided handler when the given future is ready.
+func Await[T any](f Future[T], handler func(Context, Future[T])) SelectCase {
+	return sync.Await[T](f, func(ctx sync.Context, f sync.Future[T]) {
+		handler(ctx, f)
+	})
+}
+
+// Receive calls the provided handler if the given channel can receive a value. The handler receives
+// the received value, and the ok flag indicating whether the value was received or the channel was closed.
+func Receive[T any](c Channel[T], handler func(ctx Context, v T, ok bool)) SelectCase {
+	return sync.Receive[T](c, handler)
+}
+
+// Send calls the provided handler if the given value can be sent to the channel.
+func Send[T any](c Channel[T], value *T, handler func(ctx Context)) SelectCase {
+	return sync.Send[T](c, value, handler)
+}
+
+// Default calls the provided handler if none of the other cases match.
+func Default(handler func(Context)) SelectCase {
+	return sync.Default(handler)
+}

workflow/sync.go

@@ -4,12 +4,13 @@ import (
 	"github.com/cschleiden/go-workflows/internal/sync"
 )
 
-type Context = sync.Context
+type (
+	Context   = sync.Context
+	WaitGroup = sync.WaitGroup
+)
 
 var Canceled = sync.Canceled
 
-type WaitGroup = sync.WaitGroup
-
 func NewWaitGroup() WaitGroup {
 	return sync.NewWaitGroup()
 }
@@ -18,33 +19,3 @@ func NewWaitGroup() WaitGroup {
 func Go(ctx Context, f func(ctx Context)) {
 	sync.Go(ctx, f)
 }
-
-type SelectCase = sync.SelectCase
-
-// Select is the workflow-save equivalent of the select statement.
-func Select(ctx Context, cases ...SelectCase) {
-	sync.Select(ctx, cases...)
-}
-
-// Await calls the provided handler when the given future is ready.
-func Await[T any](f Future[T], handler func(Context, Future[T])) SelectCase {
-	return sync.Await[T](f, func(ctx sync.Context, f sync.Future[T]) {
-		handler(ctx, f)
-	})
-}
-
-// Receive calls the provided handler if the given channel can receive a value. The handler receives
-// the received value, and the ok flag indicating whether the value was received or the channel was closed.
-func Receive[T any](c Channel[T], handler func(ctx Context, v T, ok bool)) SelectCase {
-	return sync.Receive[T](c, handler)
-}
-
-// Send calls the provided handler if the given value can be sent to the channel.
-func Send[T any](c Channel[T], value *T, handler func(ctx Context)) SelectCase {
-	return sync.Send[T](c, value, handler)
-}
-
-// Default calls the given handler if none of the other cases match.
-func Default(handler func(Context)) SelectCase {
-	return sync.Default(handler)
-}