vendor/symfony/mercure/src/Debug/TraceablePublisher.php line 21

Open in your IDE?
  1. <?php
  3. /*
  4. * This file is part of the Mercure Component project.
  5. *
  6. * (c) Kévin Dunglas <dunglas@gmail.com>
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  12. declare(strict_types=1);
  14. namespace Symfony\Component\Mercure\Debug;
  16. use Symfony\Component\Mercure\PublisherInterface;
  17. use Symfony\Component\Mercure\Update;
  18. use Symfony\Component\Stopwatch\Stopwatch;
  19. use Symfony\Contracts\Service\ResetInterface;
  21. trigger_deprecation('symfony/mercure', '0.5', 'Class "%s" is deprecated, use "%s" instead.', TraceablePublisher::class, TraceableHub::class);
  23. /**
  24. * Traces updates for profiler.
  25. *
  26. * @author Vincent Chalamon <vincentchalamon@gmail.com>
  27. *
  28. * @experimental
  29. *
  30. * @deprecated
  31. */
  32. final class TraceablePublisher implements PublisherInterface, ResetInterface
  33. {
  34. private $publisher;
  35. private $stopwatch;
  36. private $messages = [];
  38. public function __construct(PublisherInterface $publisher, Stopwatch $stopwatch)
  39. {
  40. $this->publisher = $publisher;
  41. $this->stopwatch = $stopwatch;
  42. }
  44. public function __invoke(Update $update): string
  45. {
  46. $this->stopwatch->start(__CLASS__);
  47. $content = ($this->publisher)($update);
  49. $e = $this->stopwatch->stop(__CLASS__);
  50. $this->messages[] = [
  51. 'object' => $update,
  52. 'duration' => $e->getDuration(),
  53. 'memory' => $e->getMemory(),
  54. ];
  56. return $content;
  57. }
  59. public function reset(): void
  60. {
  61. $this->messages = [];
  62. }
  64. public function count(): int
  65. {
  66. return \count($this->messages);
  67. }
  69. public function getMessages(): array
  70. {
  71. return $this->messages;
  72. }
  74. public function getDuration(): float
  75. {
  76. return array_sum(array_map(function ($a) {
  77. return $a['duration'];
  78. }, $this->messages));
  79. }
  81. public function getMemory(): int
  82. {
  83. return (int) array_sum(array_map(function ($a) {
  84. return $a['memory'];
  85. }, $this->messages));
  86. }
  87. }