mirror of
https://github.com/danog/amp.git
synced 2024-11-30 04:29:08 +01:00
Make Observer::drain() public
This commit is contained in:
parent
5f1354bf1a
commit
c89f10eef0
@ -115,7 +115,7 @@ class Observer {
|
||||
}
|
||||
|
||||
if ($this->resolved) {
|
||||
--$this->position;
|
||||
--$this->position;
|
||||
|
||||
if ($this->exception) {
|
||||
return new Failure($this->exception);
|
||||
@ -175,7 +175,7 @@ class Observer {
|
||||
*
|
||||
* @throws \Error If the observable has not completed.
|
||||
*/
|
||||
protected function drain(): array {
|
||||
public function drain(): array {
|
||||
if (!$this->resolved) {
|
||||
throw new \Error("The observable has not resolved");
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user