projects
/
m6w6
/
seekat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
add Amp\Loop example
[m6w6/seekat]
/
examples
/
hooks.php
diff --git
a/examples/hooks.php
b/examples/hooks.php
index ad236925ffbcde60278c96dce3eed549e7b9e06f..612e6de75dbfc014f7ac97daaf11a7152896e50a 100755
(executable)
--- a/
examples/hooks.php
+++ b/
examples/hooks.php
@@
-3,20
+3,20
@@
require_once __DIR__."/../vendor/autoload.php";
require_once __DIR__."/../vendor/autoload.php";
-use seekat\API;
+use seekat\{API, API\Future, API\Links};
+use Monolog\{Logger, Handler};
$cli = new http\Client("curl", "seekat");
$cli->configure([
"max_host_connections" => 10,
"max_total_connections" => 50,
$cli = new http\Client("curl", "seekat");
$cli->configure([
"max_host_connections" => 10,
"max_total_connections" => 50,
+ "use_eventloop" => true,
]);
]);
-$log = new
Monolog\
Logger("seekat");
-$log->pushHandler(
(new Monolog\Handler\StreamHandler(STDERR))->setLevel(Monolog\Logger::WARNING
));
+$log = new Logger("seekat");
+$log->pushHandler(
new Handler\StreamHandler(STDERR, Logger::NOTICE
));
-$api = new API([
- "Authorization" => "token ".getenv("GITHUB_TOKEN")
-], null, $cli, $log);
+$api = new API(Future\react(), API\auth("token", getenv("GITHUB_TOKEN")), null, $cli, $log);
$api(function() use($api) {
$repos = yield $api->users->m6w6->repos([
$api(function() use($api) {
$repos = yield $api->users->m6w6->repos([
@@
-24,13
+24,14
@@
$api(function() use($api) {
"affiliation" => "owner"
]);
while ($repos) {
"affiliation" => "owner"
]);
while ($repos) {
- $next =
$repos->next(
);
+ $next =
Links\next($repos
);
$batch = [];
foreach ($repos as $repo) {
$batch[] = $repo->hooks();
}
$batch = [];
foreach ($repos as $repo) {
$batch[] = $repo->hooks();
}
- foreach (yield $batch as $key => $hooks) {
+ $result = yield $batch;
+ foreach ($result as $key => $hooks) {
if (!count($hooks)) {
continue;
}
if (!count($hooks)) {
continue;
}