Skip to content
Snippets Groups Projects
Unverified Commit 04c037eb authored by Roeland Jago Douma's avatar Roeland Jago Douma
Browse files

[3rdparty] Migrate to Opis/Closure

parent 6f4d3edb
No related branches found
No related tags found
No related merge requests found
Subproject commit 8d7a96cde06a0357ce5805e00773b576d7595ef8
Subproject commit 8f03ccac97331ff781340d76a3f4a49a017d6ae1
......@@ -23,12 +23,10 @@
namespace OC\Command;
use OC\BackgroundJob\QueuedJob;
use SuperClosure\Serializer;
class ClosureJob extends QueuedJob {
protected function run($serializedCallable) {
$serializer = new Serializer();
$callable = $serializer->unserialize($serializedCallable);
$callable = \Opis\Closure\unserialize($serializedCallable);
if (is_callable($callable)) {
$callable();
} else {
......
......@@ -30,7 +30,7 @@ use OCP\Command\ICommand;
*/
class CommandJob extends QueuedJob {
protected function run($serializedCommand) {
$command = unserialize($serializedCommand);
$command = \Opis\Closure\unserialize($serializedCommand);
if ($command instanceof ICommand) {
$command->handle();
} else {
......
......@@ -26,7 +26,6 @@
namespace OC\Command;
use OCP\Command\ICommand;
use SuperClosure\Serializer;
class CronBus extends AsyncBus {
/**
......@@ -68,10 +67,9 @@ class CronBus extends AsyncBus {
*/
private function serializeCommand($command) {
if ($command instanceof \Closure) {
$serializer = new Serializer();
return $serializer->serialize($command);
return \Opis\Closure\serialize($command);
} elseif (is_callable($command) or $command instanceof ICommand) {
return serialize($command);
return \Opis\Closure\serialize($command);
} else {
throw new \InvalidArgumentException('Invalid command');
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment