Ytake\KsqlClient\Result\StatusResult::result()

Complexity

Conditions	2
Paths	2

Size

Total Lines	20
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function result(): EntityInterface
    {
        $decode = \GuzzleHttp\json_decode(
            $this->response->getBody()->getContents(), true
        );
        $statuses = new CommandStatuses();
        /**
         * response
         * {
         *   "commandStatuses": [
         *     {"stream/EXAMPLE/create":"SUCCESS"}
         *   ]
         * }
         */
        foreach ($decode['commandStatuses'] as $commandId => $status) {
            $statuses->addCommandStatus(new CommandStatus($commandId, $status));
        }

        return $statuses;
    }
}