fix(core): update

This commit is contained in:
2019-01-18 02:42:13 +01:00
parent b6b584f808
commit 6117228ea4
3 changed files with 16 additions and 10 deletions

View File

@ -43,7 +43,13 @@ export class DockerHost {
const response = await this.requestStreaming('GET', '/events');
return plugins.rxjs.Observable.create(observer => {
response.on('data', data => {
observer.next(data.toString());
const eventString = data.toString();
try {
const eventObject = JSON.parse(eventString);
observer.next(eventObject);
} catch (e) {
console.log(e);
}
});
return () => {
response.emit('end');