@@ -31,7 +31,7 @@ |
||
| 31 | 31 | { |
| 32 | 32 | $tags = $ctx->get(self::FLAG) ?? $request->getTags(); |
| 33 | 33 | if ($tags !== Tags::DEFAULT) { |
| 34 | - $request->opsExtra('h-headers', static function (&$headers) use ($request, $tags) { |
|
| 34 | + $request->opsExtra('h-headers', static function(&$headers) use ($request, $tags) { |
|
| 35 | 35 | $request->setTags(...$tags); |
| 36 | 36 | $headers[Defined::X_ROUTE_TAGS] = implode(',', $tags); |
| 37 | 37 | }); |
@@ -78,7 +78,7 @@ |
||
| 78 | 78 | |
| 79 | 79 | $headers = $this->getHeaderLines($http); |
| 80 | 80 | |
| 81 | - $request->opsExtra('h-headers', static function (&$exists) use ($headers) { |
|
| 81 | + $request->opsExtra('h-headers', static function(&$exists) use ($headers) { |
|
| 82 | 82 | $exists = array_merge($exists, $headers); |
| 83 | 83 | }); |
| 84 | 84 | |
@@ -44,7 +44,7 @@ |
||
| 44 | 44 | |
| 45 | 45 | if ($attachments) { |
| 46 | 46 | $dat = base64_encode(json_encode($attachments, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE)); |
| 47 | - $request->opsExtra('h-headers', static function (&$headers) use ($dat) { |
|
| 47 | + $request->opsExtra('h-headers', static function(&$headers) use ($dat) { |
|
| 48 | 48 | $headers[self::HTTP_HEADER] = $dat; |
| 49 | 49 | }); |
| 50 | 50 | } |
@@ -24,7 +24,7 @@ |
||
| 24 | 24 | */ |
| 25 | 25 | public function inbound($request, Context $ctx) : Promised |
| 26 | 26 | { |
| 27 | - return async(function (Request $request) { |
|
| 27 | + return async(function(Request $request) { |
|
| 28 | 28 | return $this->call($request); |
| 29 | 29 | }, $ctx, $request); |
| 30 | 30 | } |
@@ -29,7 +29,7 @@ |
||
| 29 | 29 | */ |
| 30 | 30 | public function starting(Application $app) : void |
| 31 | 31 | { |
| 32 | - $app->starting()->add(static function () { |
|
| 32 | + $app->starting()->add(static function() { |
|
| 33 | 33 | Client::layers()->prepend(Selector::class, DI::object(RoutesMarking::class)); |
| 34 | 34 | }); |
| 35 | 35 | } |
@@ -40,10 +40,10 @@ |
||
| 40 | 40 | |
| 41 | 41 | $platform = DI::get(Observer::class); |
| 42 | 42 | |
| 43 | - $platform->transportable(static function () { |
|
| 43 | + $platform->transportable(static function() { |
|
| 44 | 44 | Client::layers()->has(TracedRequesting::class) |
| 45 | 45 | || Client::layers()->append(Selector::class, DI::object(TracedRequesting::class)); |
| 46 | - }, static function () { |
|
| 46 | + }, static function() { |
|
| 47 | 47 | Client::layers()->remove(TracedRequesting::class); |
| 48 | 48 | }); |
| 49 | 49 | } |
@@ -48,7 +48,7 @@ |
||
| 48 | 48 | $c = new Clustered(DI::get(Resources::class), ...($tags ?? [])); |
| 49 | 49 | |
| 50 | 50 | // custom configure |
| 51 | - $c->configure(static function (string $server) use ($app) { |
|
| 51 | + $c->configure(static function(string $server) use ($app) { |
|
| 52 | 52 | return $app->conf()->bind( |
| 53 | 53 | (new HOptions()) |
| 54 | 54 | ->setTimeouts() |
@@ -30,7 +30,7 @@ discard block |
||
| 30 | 30 | */ |
| 31 | 31 | public function starting(Application $app) : void |
| 32 | 32 | { |
| 33 | - $handler = static function ($value) { |
|
| 33 | + $handler = static function($value) { |
|
| 34 | 34 | if (is_null($value)) { |
| 35 | 35 | Client::layers()->remove(ContextPacking::class); |
| 36 | 36 | return; |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | || Client::layers()->prepend(Invoker::class, $client); |
| 58 | 58 | }; |
| 59 | 59 | |
| 60 | - $app->starting()->add(static function () use ($app, $handler) { |
|
| 60 | + $app->starting()->add(static function() use ($app, $handler) { |
|
| 61 | 61 | $app->conf()->watching(self::CONF_KEY, $handler); |
| 62 | 62 | }); |
| 63 | 63 | } |