setName('broadcast:test')
->setDescription('test the SSE broadcaster')
->addArgument(
'uid',
InputArgument::REQUIRED,
'the UID of the users to receive the event'
)
->addArgument(
'name',
InputArgument::OPTIONAL,
'the event name',
'test'
);
}
protected function execute(InputInterface $input, OutputInterface $output): int {
$name = $input->getArgument('name');
$uid = $input->getArgument('uid');
$event = new class($name, $uid) extends ABroadcastedEvent {
/** @var string */
private $name;
/** @var string */
private $uid;
public function __construct(string $name,
string $uid) {
parent::__construct();
$this->name = $name;
$this->uid = $uid;
}
public function broadcastAs(): string {
return $this->name;
}
public function getUids(): array {
return [
$this->uid,
];
}
public function jsonSerialize(): array {
return [
'description' => 'this is a test event',
];
}
};
$this->eventDispatcher->dispatch('broadcasttest', $event);
return 0;
}
}
ion value='release/v1.8'>release/v1.8
Git with a cup of tea! Painless self-hosted all-in-one software development service, including Git hosting, code review, team collaboration, package registry and CI/CD: https://github.com/go-gitea/gitea