feat: synchronous emitter bindings (#7)

pancsta · Jan 18, 2024 · 3226f75 · 3226f75
1 parent 2e5c76e
commit 3226f75
Show file tree

Hide file tree

Showing 7 changed files with 283 additions and 316 deletions.
diff --git a/examples/temporal-expense/expense_test.go b/examples/temporal-expense/expense_test.go
@@ -231,11 +231,10 @@ func ExpenseFlow(
 	})
 
 	// bind handlers and wait for Ready
-	binding, err := machine.BindHandlers(&MachineHandlers{})
+	err := machine.BindHandlers(&MachineHandlers{})
 	if err != nil {
 		return machine, err
 	}
-	<-binding.Ready
 
 	// reusable error channel
 	errCh := machine.WhenErr(nil)

diff --git a/examples/temporal-fileprocessing/fileprocessing.go b/examples/temporal-fileprocessing/fileprocessing.go
@@ -225,11 +225,10 @@ func FileProcessingFlow(ctx context.Context, log Logger, filename string) (*am.M
 	})
 
 	// bind handlers and wait for Ready
-	binding, err := machine.BindHandlers(&MachineHandlers{})
+	err := machine.BindHandlers(&MachineHandlers{})
 	if err != nil {
 		return machine, err
 	}
-	<-binding.Ready
 
 	// start it up!
 	machine.Add(am.S{"DownloadingFile"}, am.A{"filename": filename})