StreamedResponse.php 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. <?php
  2. /*
  3. * This file is part of the Symfony package.
  4. *
  5. * (c) Fabien Potencier <fabien@symfony.com>
  6. *
  7. * For the full copyright and license information, please view the LICENSE
  8. * file that was distributed with this source code.
  9. */
  10. namespace Symfony\Component\HttpFoundation;
  11. /**
  12. * StreamedResponse represents a streamed HTTP response.
  13. *
  14. * A StreamedResponse uses a callback for its content.
  15. *
  16. * The callback should use the standard PHP functions like echo
  17. * to stream the response back to the client. The flush() method
  18. * can also be used if needed.
  19. *
  20. * @see flush()
  21. *
  22. * @author Fabien Potencier <fabien@symfony.com>
  23. *
  24. * @api
  25. */
  26. class StreamedResponse extends Response
  27. {
  28. protected $callback;
  29. protected $streamed;
  30. /**
  31. * Constructor.
  32. *
  33. * @param mixed $callback A valid PHP callback
  34. * @param integer $status The response status code
  35. * @param array $headers An array of response headers
  36. *
  37. * @api
  38. */
  39. public function __construct($callback = null, $status = 200, $headers = array())
  40. {
  41. parent::__construct(null, $status, $headers);
  42. if (null !== $callback) {
  43. $this->setCallback($callback);
  44. }
  45. $this->streamed = false;
  46. }
  47. /**
  48. * {@inheritDoc}
  49. */
  50. public static function create($callback = null, $status = 200, $headers = array())
  51. {
  52. return new static($callback, $status, $headers);
  53. }
  54. /**
  55. * Sets the PHP callback associated with this Response.
  56. *
  57. * @param mixed $callback A valid PHP callback
  58. *
  59. * @throws \LogicException
  60. */
  61. public function setCallback($callback)
  62. {
  63. if (!is_callable($callback)) {
  64. throw new \LogicException('The Response callback must be a valid PHP callable.');
  65. }
  66. $this->callback = $callback;
  67. }
  68. /**
  69. * {@inheritdoc}
  70. */
  71. public function prepare(Request $request)
  72. {
  73. $this->headers->set('Cache-Control', 'no-cache');
  74. return parent::prepare($request);
  75. }
  76. /**
  77. * {@inheritdoc}
  78. *
  79. * This method only sends the content once.
  80. */
  81. public function sendContent()
  82. {
  83. if ($this->streamed) {
  84. return;
  85. }
  86. $this->streamed = true;
  87. if (null === $this->callback) {
  88. throw new \LogicException('The Response callback must not be null.');
  89. }
  90. call_user_func($this->callback);
  91. }
  92. /**
  93. * {@inheritdoc}
  94. *
  95. * @throws \LogicException when the content is not null
  96. */
  97. public function setContent($content)
  98. {
  99. if (null !== $content) {
  100. throw new \LogicException('The content cannot be set on a StreamedResponse instance.');
  101. }
  102. }
  103. /**
  104. * {@inheritdoc}
  105. *
  106. * @return false
  107. */
  108. public function getContent()
  109. {
  110. return false;
  111. }
  112. }