Method updateCompleted has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    int $taskId,
    array $completeList = [],
    ?callable $onClear = null,
    bool $cancel = false,
    bool $forceUpdate = false

Method spawn_progress has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    $command,
    $channel = null,
    $channelTask = null,
    $timeout = 0,
    bool $display = false

Function log has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function log($level, $message, array $context = [])
  {
    if (false === $level = \array_search($level, self::$levels, true)) {
      yield $this->close();
      throw new InvalidArgumentException(\sprintf("Unknown logger(%s) level name: '%s'", $this->name, $level));

• Read up
  Read up

Function close has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function close(): void
  {
    if ($this->withSet)
      $this->clearWith();

• Read up
  Read up

Function __construct has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function __construct(array $tasks = [], string $wait = 'all')
  {
    $coroutine = \coroutine();
    $this->wait = $wait;
    foreach ($tasks as $tid) {

• Read up
  Read up

Function shutdown has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function shutdown(int $how = 2)
  {
    if ($this->secured) {
      if (\is_resource($this->stream))
        \stream_socket_shutdown($this->stream, $how);

• Read up
  Read up

Function tick has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function tick(FutureInterface $future)
  {
    if (!$this->coroutine instanceof CoroutineInterface || $this->isKilling)
      return;

• Read up
  Read up

Function progressTask has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public static function progressTask(callable $handler)
  {
    return Kernel::away(function () use ($handler) {
      yield;
      while (true) {

• Read up
  Read up

Function logger_shutdown has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  function logger_shutdown()
  {
    $loggerTags = Log::allLogs();
    if (!empty($loggerTags)) {
      $names = \array_keys((array) $loggerTags);

• Read up
  Read up

Function wait has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function wait(): array
  {
    while (true) {
      if (!$this->coroutine instanceof CoroutineInterface)
        break;

• Read up
  Read up

Function timeout has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function timeout()
  {
    $coroutine = \coroutine();
    $timeout = $this->clock;
    $task = $this->withTask();

• Read up
  Read up

Function ending has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  function ending(ContextInterface $context)
  {
    try {
      if ($context() instanceof \Generator)
        yield $context();

• Read up
  Read up

Function close has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function close(): void
  {
    if (!$this->closed) {
      $this->shutdown(2);
      $this->clearError();

• Read up
  Read up

Function write has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function write(string $data, ?int $length = 0)
  {
    $count = false;
    $length = (empty($length) ? \strlen($data) : $length);
    if ($this->closed) {

• Read up
  Read up

Function __construct has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  private function __construct($prev, $callback, $args, $recover = false)
  {
    if ($recover) {
      self::$isRecoverable = true;
      self::$recoverable = $callback;

• Read up
  Read up

Function ioSocketStream has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  protected function ioSocketStream($timeout)
  {
    if (empty($this->waitingForRead) && empty($this->waitingForWrite)) {
      return;
    }

• Read up
  Read up

Function addSignal has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  public function addSignal($signal, $listener)
  {
    if (!$this->signaler)
      return;

• Read up
  Read up

Avoid too many return statements within this method.

Open

    return isset($meta[$info]) ? $meta[$info] : $meta;

Avoid too many return statements within this method.

Open

        return yield $misc_function(...$arguments);

Avoid too many return statements within this method.

Open

      return yield Co::getFunction($label)(...$arguments);