$source = isset( $_REQUEST['source'] ) ? trim($_REQUEST['source'], '/\\') : '';
if($source) {
- $eventSource = \OC::$server->getEventSource();
+ $eventSource = \OC::$server->createEventSource();
} else {
OC_JSON::callCheck();
}
$users = array(OC_User::getUser());
}
-$eventSource = \OC::$server->getEventSource();
+$eventSource = \OC::$server->createEventSource();
$listener = new ScanListener($eventSource);
foreach ($users as $user) {
if (OC::checkUpgrade(false)) {
$l = new \OC_L10N('core');
- $eventSource = \OC::$server->getEventSource();
+ $eventSource = \OC::$server->createEventSource();
$updater = new \OC\Updater(\OC_Log::$object);
$updater->listen('\OC\Updater', 'maintenanceStart', function () use ($eventSource, $l) {
$eventSource->send('success', (string)$l->t('Turned on maintenance mode'));
* @return \OCP\IEventSource a new open EventSource class
*/
public function openEventSource(){
- return \OC::$server->getEventSource();
+ return \OC::$server->createEventSource();
}
/**
}
/**
- * Returns a search instance
+ * Create a new event source
*
* @return \OCP\IEventSource
*/
- function getEventSource() {
+ function createEventSource() {
return new \OC_EventSource();
}
}
* includes a fallback for older browsers and IE
*
* use server side events with caution, to many open requests can hang the server
+ *
+ * The event source will initialize the connection to the client when the first data is sent
*/
interface IEventSource {
/**
function getCertificateManager($user = null);
/**
- * Returns a search instance
+ * Create a new event source
*
* @return \OCP\IEventSource
*/
- function getEventSource();
+ function createEventSource();
}