@@ 112-125 (lines=14) @@ | ||
109 | /** |
|
110 | * @return EventStreamInterface[] |
|
111 | */ |
|
112 | public function readAllStreams() |
|
113 | { |
|
114 | $stmt = $this->connection->prepare( |
|
115 | 'SELECT * |
|
116 | FROM streams' |
|
117 | ); |
|
118 | $stmt->execute(); |
|
119 | ||
120 | $streams = []; |
|
121 | foreach ($stmt->fetchAll() as $result) { |
|
122 | $streams[] = $this->readFullStream($result['id']); |
|
123 | } |
|
124 | return $streams; |
|
125 | } |
|
126 | ||
127 | /** |
|
128 | * @return EventStreamInterface |
@@ 113-126 (lines=14) @@ | ||
110 | /** |
|
111 | * @return EventStreamInterface[] |
|
112 | */ |
|
113 | public function readAllStreams() |
|
114 | { |
|
115 | $stmt = $this->connection->prepare( |
|
116 | 'SELECT * |
|
117 | FROM streams' |
|
118 | ); |
|
119 | $stmt->execute(); |
|
120 | ||
121 | $streams = []; |
|
122 | foreach ($stmt->fetchAll() as $result) { |
|
123 | $streams[] = $this->readFullStream($result['id']); |
|
124 | } |
|
125 | return $streams; |
|
126 | } |
|
127 | ||
128 | /** |
|
129 | * @return EventStreamInterface |