@@ -88,6 +88,7 @@ public function __construct(
8888
8989 // Build Config from array or named params
9090 if (\is_array ($ config )) {
91+ /** @var array{host?: string, ports?: array<int, int>, workers?: int, max_connections?: int, max_coroutine?: int, socket_buffer_size?: int, buffer_output_size?: int, reactor_num?: int|null, dispatch_mode?: int, enable_reuse_port?: bool, backlog?: int, package_max_length?: int, tcp_keepidle?: int, tcp_keepinterval?: int, tcp_keepcount?: int, enable_coroutine?: bool, max_wait_time?: int, log_level?: int, log_connections?: bool, recv_buffer_size?: int, backend_connect_timeout?: float, skip_validation?: bool, read_write_split?: bool, tls?: TLS|null, adapter_factory?: \Closure|null} $config */
9192 $ this ->config = self ::buildConfig ($ config , $ host , $ ports , $ workers );
9293 } elseif ($ config instanceof Config) {
9394 $ this ->config = $ config ;
@@ -138,9 +139,8 @@ public function __construct(
138139 }
139140
140141 /**
141- * Build a Config object from an associative array of settings
142- *
143- * @param array<string, mixed> $settings
142+ * @param array{host?: string, ports?: array<int, int>, workers?: int, max_connections?: int, max_coroutine?: int, socket_buffer_size?: int, buffer_output_size?: int, reactor_num?: int|null, dispatch_mode?: int, enable_reuse_port?: bool, backlog?: int, package_max_length?: int, tcp_keepidle?: int, tcp_keepinterval?: int, tcp_keepcount?: int, enable_coroutine?: bool, max_wait_time?: int, log_level?: int, log_connections?: bool, recv_buffer_size?: int, backend_connect_timeout?: float, skip_validation?: bool, read_write_split?: bool, tls?: TLS|null, adapter_factory?: \Closure|null} $settings
143+ * @param array<int, int>|null $ports
144144 */
145145 protected static function buildConfig (
146146 array $ settings ,
@@ -244,6 +244,7 @@ public function onWorkerStart(Server $server, int $workerId): void
244244 // Initialize TCP adapter per worker per port
245245 foreach ($ this ->config ->ports as $ port ) {
246246 if ($ this ->config ->adapterFactory !== null ) {
247+ /** @var TCPAdapter $adapter */
247248 $ adapter = ($ this ->config ->adapterFactory )($ port );
248249 } else {
249250 $ adapter = new TCPAdapter ($ this ->resolver , port: $ port );
0 commit comments