1 | <?php |
||
19 | class JsonStream |
||
20 | { |
||
21 | /** |
||
22 | * @var string[] |
||
23 | */ |
||
24 | const JSON_STARTS_WITH = ['{', '[']; |
||
25 | |||
26 | /** |
||
27 | * @var int |
||
28 | */ |
||
29 | const BUFFER_MAX_SIZE = 2 ** 14; |
||
30 | |||
31 | /** |
||
32 | * @var string |
||
33 | */ |
||
34 | private $bufferSize; |
||
35 | |||
36 | /** |
||
37 | * @var string |
||
38 | */ |
||
39 | private $endsWith = ']'; |
||
40 | |||
41 | /** |
||
42 | * @var string |
||
43 | */ |
||
44 | private $buffer = ''; |
||
45 | |||
46 | /** |
||
47 | * @var int |
||
48 | */ |
||
49 | private $chunkSize = 1; |
||
50 | |||
51 | /** |
||
52 | * @var LoggerInterface |
||
53 | */ |
||
54 | private $logger; |
||
55 | |||
56 | /** |
||
57 | * JsonStream constructor. |
||
58 | * @param int $bufferSize |
||
59 | */ |
||
60 | public function __construct(int $bufferSize = self::BUFFER_MAX_SIZE) |
||
64 | |||
65 | /** |
||
66 | * @param LoggerInterface $logger |
||
67 | */ |
||
68 | public function setLogger(LoggerInterface $logger) |
||
72 | |||
73 | /** |
||
74 | * @throws \OutOfBoundsException |
||
75 | */ |
||
76 | private function checkSize() |
||
84 | |||
85 | /** |
||
86 | * @param string $data |
||
87 | * @return bool |
||
88 | */ |
||
89 | private function shouldStarts(string $data): bool |
||
93 | |||
94 | /** |
||
95 | * @param string $data |
||
96 | * @param \Closure|null $callback |
||
97 | * @return mixed|null |
||
98 | */ |
||
99 | public function push(string $data, \Closure $callback = null) |
||
130 | |||
131 | /** |
||
132 | * @param string $text |
||
133 | * @return bool |
||
134 | */ |
||
135 | private function isEnds(string $text): bool |
||
141 | |||
142 | /** |
||
143 | * @param StreamInterface $stream |
||
144 | * @return \Generator |
||
145 | * @throws \OutOfBoundsException |
||
146 | * @throws \RuntimeException |
||
147 | */ |
||
148 | public function stream(StreamInterface $stream): \Generator |
||
161 | } |
||
162 |