@@ -76,7 +76,7 @@ public function overview(): PromiseInterface
76
76
new SimpleRequestCommand ('overview ' )
77
77
)->then (function (ResponseInterface $ response ) {
78
78
return resolve ($ this ->client ->handle (
79
- new HydrateCommand ('Overview ' , $ response ->getBody ()->getJson ())
79
+ new HydrateCommand ('Overview ' , $ response ->getBody ()->getParsedContents ())
80
80
));
81
81
});
82
82
}
@@ -91,7 +91,7 @@ public function queues(int $interval = null): ObservableInterface
91
91
return Promise::toObservable ($ this ->client ->handle (
92
92
new SimpleRequestCommand ('queues ' )
93
93
))->flatMap (function (ResponseInterface $ response ) {
94
- return observableFromArray ($ response ->getBody ()->getJson ());
94
+ return observableFromArray ($ response ->getBody ()->getParsedContents ());
95
95
})->flatMap (function ($ queue ) {
96
96
return Promise::toObservable ($ this ->client ->handle (
97
97
new HydrateCommand ('Queue ' , $ queue )
@@ -114,7 +114,7 @@ public function connections(): ObservableInterface
114
114
return Promise::toObservable ($ this ->client ->handle (
115
115
new SimpleRequestCommand ('connections ' )
116
116
))->flatMap (function (ResponseInterface $ response ) {
117
- return observableFromArray ($ response ->getBody ()->getJson ());
117
+ return observableFromArray ($ response ->getBody ()->getParsedContents ());
118
118
})->flatMap (function ($ connection ) {
119
119
return Promise::toObservable ($ this ->client ->handle (
120
120
new HydrateCommand ('Connection ' , $ connection )
0 commit comments