Skip to content

Commit c66ac4d

Browse files
authored
Update HttpObservable.php
1 parent bd85e35 commit c66ac4d

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/HttpObservable.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,11 @@ protected function _subscribe(ObserverInterface $observer): DisposableInterface
9898
});
9999
});
100100
$request->end($this->body);
101+
102+
$request->on('error', function ($e) use ($observer) {
103+
$error = new \Exception($e);
104+
$observer->onError($error);
105+
});
101106

102107
return new CallbackDisposable(function () use ($request) {
103108
$request->close();

0 commit comments

Comments
 (0)