@@ -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 | } |