Rename context selector Receive

Author: cschleiden

internal/sync/context.go

@@ -184,7 +184,7 @@ func propagateCancel(parent Context, child canceler) {
 
 	Select(
 		parent,
-		ReceiveChan(done, func(ctx Context, c Channel) {
+		Receive(done, func(ctx Context, c Channel) {
 			// Parent is already canceled
 			child.cancel(false, parent.Err())
 		}),

internal/sync/context_test.go

@@ -25,7 +25,7 @@ func TestWithCancel(t *testing.T) {
 
 		Select(
 			ctx,
-			ReceiveChan(ctx.Done(), func(ctx Context, c Channel) {
+			Receive(ctx.Done(), func(ctx Context, c Channel) {
 				canceled = true
 			}),
 		)

internal/sync/selector.go

@@ -22,7 +22,7 @@ func Await(f Future, handler func(Context, Future)) SelectCase {
 	}
 }
 
-func ReceiveChan(c Channel, handler func(Context, Channel)) SelectCase {
+func Receive(c Channel, handler func(Context, Channel)) SelectCase {
 	channel := c.(*channel)
 
 	return &channelCase{

internal/sync/selector_test.go

@@ -132,7 +132,7 @@ func Test_ChannelSelector_Select(t *testing.T) {
 		// Wait for result
 		Select(
 			ctx,
-			ReceiveChan(c, func(ctx Context, c Channel) {
+			Receive(c, func(ctx Context, c Channel) {
 				c.Receive(ctx, &r)
 			}),
 		)

samples/signal/signal.go

@@ -77,7 +77,7 @@ func Workflow1(ctx workflow.Context, msg string, subID string) (string, error) {
 
 	log.Println("Waiting for first signal")
 	workflow.Select(ctx,
-		workflow.ReceiveChan(workflow.NewSignalChannel(ctx, "test"), func(ctx workflow.Context, c sync.Channel) {
+		workflow.Receive(workflow.NewSignalChannel(ctx, "test"), func(ctx workflow.Context, c sync.Channel) {
 			var r int
 			c.Receive(ctx, &r)
 
@@ -106,7 +106,7 @@ func SubWorkflow1(ctx workflow.Context) (string, error) {
 	defer log.Println("Leaving SubWorkflow1")
 
 	workflow.Select(ctx,
-		workflow.ReceiveChan(workflow.NewSignalChannel(ctx, "sub-signal"), func(ctx workflow.Context, c sync.Channel) {
+		workflow.Receive(workflow.NewSignalChannel(ctx, "sub-signal"), func(ctx workflow.Context, c sync.Channel) {
 			c.Receive(ctx, nil)
 		}),
 	)

workflow/workflow.go

@@ -75,8 +75,8 @@ func Await(f Future, handler func(Context, Future)) SelectCase {
 	return sync.Await(f, handler)
 }
 
-func ReceiveChan(c Channel, handler func(Context, Channel)) SelectCase {
-	return sync.ReceiveChan(c, handler)
+func Receive(c Channel, handler func(Context, Channel)) SelectCase {
+	return sync.Receive(c, handler)
 }
 
 func Default(handler func(Context)) SelectCase {