summaryrefslogtreecommitdiff
path: root/tests/temporal/Workflow/LoopWorkflow.php
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-27 13:56:28 +0300
committerValery Piashchynski <[email protected]>2021-01-27 13:56:28 +0300
commit744c2b0c86b88f77e681f8660bf3a476e83711b8 (patch)
treef7af7d7d494d1f5ca272af1ad0b978fe44d685a9 /tests/temporal/Workflow/LoopWorkflow.php
parente2266b80db47444ba5858c736833a8a81b1361ad (diff)
Move temporal plugin to the temporal repository
Diffstat (limited to 'tests/temporal/Workflow/LoopWorkflow.php')
-rw-r--r--tests/temporal/Workflow/LoopWorkflow.php51
1 files changed, 0 insertions, 51 deletions
diff --git a/tests/temporal/Workflow/LoopWorkflow.php b/tests/temporal/Workflow/LoopWorkflow.php
deleted file mode 100644
index 97d7a3aa..00000000
--- a/tests/temporal/Workflow/LoopWorkflow.php
+++ /dev/null
@@ -1,51 +0,0 @@
-<?php
-
-
-namespace Temporal\Tests\Workflow;
-
-use Temporal\Activity\ActivityOptions;
-use Temporal\Tests\Activity\SimpleActivity;
-use Temporal\Workflow;
-use Temporal\Workflow\SignalMethod;
-use Temporal\Workflow\WorkflowMethod;
-
-#[Workflow\WorkflowInterface]
-class LoopWorkflow
-{
- private array $values = [];
- private array $result = [];
- private $simple;
-
- public function __construct()
- {
- $this->simple = Workflow::newActivityStub(
- SimpleActivity::class,
- ActivityOptions::new()->withStartToCloseTimeout(5)
- );
- }
-
- #[SignalMethod]
- public function addValue(
- string $value
- ) {
- $this->values[] = $value;
- }
-
- #[WorkflowMethod(name: 'LoopWorkflow')]
- public function run(
- int $count
- ) {
- while (true) {
- yield Workflow::await(fn() => $this->values !== []);
- $value = array_shift($this->values);
-
- $this->result[] = yield $this->simple->echo($value);
-
- if (count($this->result) === $count) {
- break;
- }
- }
-
- return $this->result;
- }
-}