Skip to content

Commit 5d869d4

Browse files
committed
Remove JobBuilders
1 parent 69cd42d commit 5d869d4

File tree

4 files changed

+5
-171
lines changed

4 files changed

+5
-171
lines changed

README.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,17 +33,17 @@ $task = JobBuilder::fromService('service_foo', ['bar', 'baz'])
3333
```
3434

3535
```php
36+
use App\Job\MyJob\MyJobHandler;
3637
use Tarantool\JobQueue\JobBuilder\JobBuilder;
37-
use Tarantool\JobQueue\JobBuilder\JobBuilders;
3838
use Tarantool\JobQueue\JobBuilder\JobEmitter;
3939

4040
...
4141

42-
$jobBuilders = new JobBuilders((static function () use ($ids) {
42+
$jobBuilders = (static function () use ($ids) {
4343
foreach ($ids as $id) {
44-
yield JobBuilder::fromService(MyHandler::class, ['id' => $id]);
44+
yield JobBuilder::fromService(MyJobHandler::class, ['id' => $id]);
4545
}
46-
})());
46+
})();
4747

4848
(new JobEmitter())->emit($jobBuilders, $queue);
4949
```

src/JobBuilders.php

Lines changed: 0 additions & 51 deletions
This file was deleted.

src/JobEmitter.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818

1919
final class JobEmitter
2020
{
21-
public function emit(JobBuilders $jobBuilders, Queue $queue) : array
21+
public function emit(iterable $jobBuilders, Queue $queue) : array
2222
{
2323
$jobs = [];
2424
foreach ($jobBuilders as $key => $jobBuilder) {

tests/JobBuildersTest.php

Lines changed: 0 additions & 115 deletions
This file was deleted.

0 commit comments

Comments
 (0)