refactor(std): time.Sleep -> time.After

examples/time_sleep/e2e_test.go → examples/time_after/e2e_test.go

@@ -17,7 +17,7 @@ func Test(t *testing.T) {
 	require.NoError(t, err)
 	defer os.Chdir(wd)
 
-	cmd := exec.Command("neva", "run", "time_sleep")
+	cmd := exec.Command("neva", "run", "time_after")
 
 	before := time.Now()
 	out, err := cmd.CombinedOutput()

examples/time_after/main.neva

@@ -0,0 +1,7 @@
+import { time }
+
+flow Main(start) (stop) {
+	time.After
+	---
+	:start -> ($time.second -> after -> :stop)
+}

internal/runtime/funcs/registry.go

@@ -75,7 +75,7 @@ func CreatorRegistry() map[string]runtime.FuncCreator {
 
 		// time
 		"time_delay": timeDelay{},
-		"time_sleep": timeSleep{},
+		"time_after": timeAfter{},
 
 		// strings
 		"string_at":   stringAt{},

internal/runtime/funcs/time_sleep.go

@@ -7,9 +7,9 @@ import (
 	"github.com/nevalang/neva/internal/runtime"
 )
 
-type timeSleep struct{}
+type timeAfter struct{}
 
-func (timeSleep) Create(io runtime.IO, _ runtime.Msg) (func(ctx context.Context), error) {
+func (timeAfter) Create(io runtime.IO, _ runtime.Msg) (func(ctx context.Context), error) {
 	durIn, err := io.In.Single("dur")
 	if err != nil {
 		return nil, err

std/builtin/bool.neva

@@ -1,5 +1,3 @@
-// TODO: rename
-
 #extern(eq)
 pub flow Eq<T>(actual T, compared T) (res bool)
 

std/time/time.neva

@@ -8,11 +8,11 @@ pub const second      Duration = 1000000000
 pub const minute      Duration = 60000000000
 pub const hour        Duration = 3600000000000
 
-// Sleep blocks the flow for (at least) provided duration.
+// After blocks the flow for (at least) provided duration.
 // When enough time has passed, it sends a signal to its output port.
 // If you want to delay a message, use Delay instead.
-#extern(time_sleep)
-pub flow Sleep(dur Duration) (sig)
+#extern(time_after)
+pub flow After(dur Duration) (sig)
 
 // Delay waits for both dur and data messages.
 // As soon as they both arrive it starts waiting