提交 461fd762 编写于 作者: Z zhuhan

fix

Signed-off-by: Nzhuhan <zhuhan10@huawei.com>
Change-Id: I8b690f4db2d85015e1f64399786c7fbd3e3b126f
上级 cfb29608
...@@ -192,7 +192,7 @@ publish(event: string, callback: AsyncCallback\<void>): void ...@@ -192,7 +192,7 @@ publish(event: string, callback: AsyncCallback\<void>): void
```js ```js
//发布公共事件回调 //发布公共事件回调
function PublishCallBack(err) { function publishCallBack(err) {
if (err.code) { if (err.code) {
console.error("publish failed " + JSON.stringify(err)); console.error("publish failed " + JSON.stringify(err));
} else { } else {
...@@ -201,7 +201,7 @@ function PublishCallBack(err) { ...@@ -201,7 +201,7 @@ function PublishCallBack(err) {
} }
//发布公共事件 //发布公共事件
CommonEvent.publish("event", PublishCallBack); CommonEvent.publish("event", publishCallBack);
``` ```
...@@ -234,7 +234,7 @@ let options = { ...@@ -234,7 +234,7 @@ let options = {
} }
//发布公共事件回调 //发布公共事件回调
function PublishCallBack(err) { function publishCallBack(err) {
if (err.code) { if (err.code) {
console.error("publish failed " + JSON.stringify(err)); console.error("publish failed " + JSON.stringify(err));
} else { } else {
...@@ -243,7 +243,7 @@ function PublishCallBack(err) { ...@@ -243,7 +243,7 @@ function PublishCallBack(err) {
} }
//发布公共事件 //发布公共事件
CommonEvent.publish("event", options, PublishCallBack); CommonEvent.publish("event", options, publishCallBack);
``` ```
...@@ -270,7 +270,7 @@ publishAsUser(event: string, userId: number, callback: AsyncCallback\<void>): vo ...@@ -270,7 +270,7 @@ publishAsUser(event: string, userId: number, callback: AsyncCallback\<void>): vo
```js ```js
//发布公共事件回调 //发布公共事件回调
function PublishAsUserCallBack(err) { function publishAsUserCallBack(err) {
if (err.code) { if (err.code) {
console.error("publishAsUser failed " + JSON.stringify(err)); console.error("publishAsUser failed " + JSON.stringify(err));
} else { } else {
...@@ -282,7 +282,7 @@ function PublishAsUserCallBack(err) { ...@@ -282,7 +282,7 @@ function PublishAsUserCallBack(err) {
let userId = 100; let userId = 100;
//发布公共事件 //发布公共事件
CommonEvent.publishAsUser("event", userId, PublishAsUserCallBack); CommonEvent.publishAsUser("event", userId, publishAsUserCallBack);
``` ```
...@@ -317,7 +317,7 @@ let options = { ...@@ -317,7 +317,7 @@ let options = {
} }
//发布公共事件回调 //发布公共事件回调
function PublishAsUserCallBack(err) { function publishAsUserCallBack(err) {
if (err.code) { if (err.code) {
console.error("publishAsUser failed " + JSON.stringify(err)); console.error("publishAsUser failed " + JSON.stringify(err));
} else { } else {
...@@ -329,7 +329,7 @@ function PublishAsUserCallBack(err) { ...@@ -329,7 +329,7 @@ function PublishAsUserCallBack(err) {
let userId = 100; let userId = 100;
//发布公共事件 //发布公共事件
CommonEvent.publishAsUser("event", userId, options, PublishAsUserCallBack); CommonEvent.publishAsUser("event", userId, options, publishAsUserCallBack);
``` ```
...@@ -361,7 +361,7 @@ let subscribeInfo = { ...@@ -361,7 +361,7 @@ let subscribeInfo = {
}; };
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if (err.code) { if (err.code) {
console.error("createSubscriber failed " + JSON.stringify(err)); console.error("createSubscriber failed " + JSON.stringify(err));
} else { } else {
...@@ -371,7 +371,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) { ...@@ -371,7 +371,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) {
} }
//创建订阅者 //创建订阅者
CommonEvent.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEvent.createSubscriber(subscribeInfo, createSubscriberCallBack);
``` ```
...@@ -442,7 +442,7 @@ let subscribeInfo = { ...@@ -442,7 +442,7 @@ let subscribeInfo = {
}; };
//订阅公共事件回调 //订阅公共事件回调
function SubscribeCallBack(err, data) { function subscribeCallBack(err, data) {
if (err.code) { if (err.code) {
console.error("subscribe failed " + JSON.stringify(err)); console.error("subscribe failed " + JSON.stringify(err));
} else { } else {
...@@ -451,19 +451,19 @@ function SubscribeCallBack(err, data) { ...@@ -451,19 +451,19 @@ function SubscribeCallBack(err, data) {
} }
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if (err.code) { if (err.code) {
console.error("createSubscriber failed " + JSON.stringify(err)); console.error("createSubscriber failed " + JSON.stringify(err));
} else { } else {
console.info("createSubscriber"); console.info("createSubscriber");
subscriber = commonEventSubscriber; subscriber = commonEventSubscriber;
//订阅公共事件 //订阅公共事件
CommonEvent.subscribe(subscriber, SubscribeCallBack); CommonEvent.subscribe(subscriber, subscribeCallBack);
} }
} }
//创建订阅者 //创建订阅者
CommonEvent.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEvent.createSubscriber(subscribeInfo, createSubscriberCallBack);
``` ```
...@@ -494,7 +494,7 @@ let subscribeInfo = { ...@@ -494,7 +494,7 @@ let subscribeInfo = {
}; };
//订阅公共事件回调 //订阅公共事件回调
function SubscribeCallBack(err, data) { function subscribeCallBack(err, data) {
if (err.code) { if (err.code) {
console.info("subscribe failed " + JSON.stringify(err)); console.info("subscribe failed " + JSON.stringify(err));
} else { } else {
...@@ -503,19 +503,19 @@ function SubscribeCallBack(err, data) { ...@@ -503,19 +503,19 @@ function SubscribeCallBack(err, data) {
} }
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if (err.code) { if (err.code) {
console.info("createSubscriber failed " + JSON.stringify(err)); console.info("createSubscriber failed " + JSON.stringify(err));
} else { } else {
console.info("createSubscriber"); console.info("createSubscriber");
subscriber = commonEventSubscriber; subscriber = commonEventSubscriber;
//订阅公共事件 //订阅公共事件
CommonEvent.subscribe(subscriber, SubscribeCallBack); CommonEvent.subscribe(subscriber, subscribeCallBack);
} }
} }
//取消订阅公共事件回调 //取消订阅公共事件回调
function UnsubscribeCallBack(err) { function unsubscribeCallBack(err) {
if (err.code) { if (err.code) {
console.info("unsubscribe failed " + JSON.stringify(err)); console.info("unsubscribe failed " + JSON.stringify(err));
} else { } else {
...@@ -524,10 +524,10 @@ function UnsubscribeCallBack(err) { ...@@ -524,10 +524,10 @@ function UnsubscribeCallBack(err) {
} }
//创建订阅者 //创建订阅者
CommonEvent.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEvent.createSubscriber(subscribeInfo, createSubscriberCallBack);
//取消订阅公共事件 //取消订阅公共事件
CommonEvent.unsubscribe(subscriber, UnsubscribeCallBack); CommonEvent.unsubscribe(subscriber, unsubscribeCallBack);
``` ```
## CommonEventSubscriber ## CommonEventSubscriber
......
...@@ -206,7 +206,7 @@ publish(event: string, callback: AsyncCallback\<void>): void ...@@ -206,7 +206,7 @@ publish(event: string, callback: AsyncCallback\<void>): void
```ts ```ts
//发布公共事件回调 //发布公共事件回调
function PublishCallBack(err) { function publishCallBack(err) {
if (err) { if (err) {
console.error("publish failed " + JSON.stringify(err)); console.error("publish failed " + JSON.stringify(err));
} else { } else {
...@@ -216,7 +216,7 @@ function PublishCallBack(err) { ...@@ -216,7 +216,7 @@ function PublishCallBack(err) {
//发布公共事件 //发布公共事件
try { try {
CommonEventManager.publish("event", PublishCallBack); CommonEventManager.publish("event", publishCallBack);
} catch(err) { } catch(err) {
console.error('publish failed, catch error' + JSON.stringify(err)); console.error('publish failed, catch error' + JSON.stringify(err));
} }
...@@ -259,7 +259,7 @@ var options = { ...@@ -259,7 +259,7 @@ var options = {
} }
//发布公共事件回调 //发布公共事件回调
function PublishCallBack(err) { function publishCallBack(err) {
if (err) { if (err) {
console.error("publish failed " + JSON.stringify(err)); console.error("publish failed " + JSON.stringify(err));
} else { } else {
...@@ -269,7 +269,7 @@ function PublishCallBack(err) { ...@@ -269,7 +269,7 @@ function PublishCallBack(err) {
//发布公共事件 //发布公共事件
try { try {
CommonEventManager.publish("event", options, PublishCallBack); CommonEventManager.publish("event", options, publishCallBack);
} catch (err) { } catch (err) {
console.error('publish failed, catch error' + JSON.stringify(err)); console.error('publish failed, catch error' + JSON.stringify(err));
} }
...@@ -307,7 +307,7 @@ publishAsUser(event: string, userId: number, callback: AsyncCallback\<void>): vo ...@@ -307,7 +307,7 @@ publishAsUser(event: string, userId: number, callback: AsyncCallback\<void>): vo
```ts ```ts
//发布公共事件回调 //发布公共事件回调
function PublishAsUserCallBack(err) { function publishAsUserCallBack(err) {
if (err) { if (err) {
console.error("publishAsUser failed " + JSON.stringify(err)); console.error("publishAsUser failed " + JSON.stringify(err));
} else { } else {
...@@ -320,7 +320,7 @@ var userId = 100; ...@@ -320,7 +320,7 @@ var userId = 100;
//发布公共事件 //发布公共事件
try { try {
CommonEventManager.publishAsUser("event", userId, PublishAsUserCallBack); CommonEventManager.publishAsUser("event", userId, publishAsUserCallBack);
} catch (err) { } catch (err) {
console.error('publishAsUser failed, catch error' + JSON.stringify(err)); console.error('publishAsUser failed, catch error' + JSON.stringify(err));
} }
...@@ -366,7 +366,7 @@ var options = { ...@@ -366,7 +366,7 @@ var options = {
} }
//发布公共事件回调 //发布公共事件回调
function PublishAsUserCallBack(err) { function publishAsUserCallBack(err) {
if (err) { if (err) {
console.error("publishAsUser failed " + JSON.stringify(err)); console.error("publishAsUser failed " + JSON.stringify(err));
} else { } else {
...@@ -379,7 +379,7 @@ var userId = 100; ...@@ -379,7 +379,7 @@ var userId = 100;
//发布公共事件 //发布公共事件
try { try {
CommonEventManager.publishAsUser("event", userId, options, PublishAsUserCallBack); CommonEventManager.publishAsUser("event", userId, options, publishAsUserCallBack);
} catch (err) { } catch (err) {
console.error('publishAsUser failed, catch error' + JSON.stringify(err)); console.error('publishAsUser failed, catch error' + JSON.stringify(err));
} }
...@@ -414,7 +414,7 @@ var subscribeInfo = { ...@@ -414,7 +414,7 @@ var subscribeInfo = {
}; };
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if(!err) { if(!err) {
console.info("createSubscriber"); console.info("createSubscriber");
subscriber = commonEventSubscriber; subscriber = commonEventSubscriber;
...@@ -425,7 +425,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) { ...@@ -425,7 +425,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) {
//创建订阅者 //创建订阅者
try { try {
CommonEventManager.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEventManager.createSubscriber(subscribeInfo, createSubscriberCallBack);
} catch (err) { } catch (err) {
console.error('createSubscriber failed, catch error' + JSON.stringify(err)); console.error('createSubscriber failed, catch error' + JSON.stringify(err));
} }
...@@ -514,7 +514,7 @@ function SubscribeCallBack(err, data) { ...@@ -514,7 +514,7 @@ function SubscribeCallBack(err, data) {
} }
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if(!err) { if(!err) {
console.info("createSubscriber"); console.info("createSubscriber");
subscriber = commonEventSubscriber; subscriber = commonEventSubscriber;
...@@ -531,7 +531,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) { ...@@ -531,7 +531,7 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) {
//创建订阅者 //创建订阅者
try { try {
CommonEventManager.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEventManager.createSubscriber(subscribeInfo, createSubscriberCallBack);
} catch (err) { } catch (err) {
console.error('createSubscriber failed, catch error' + JSON.stringify(err)); console.error('createSubscriber failed, catch error' + JSON.stringify(err));
} }
...@@ -563,7 +563,7 @@ var subscribeInfo = { ...@@ -563,7 +563,7 @@ var subscribeInfo = {
events: ["event"] events: ["event"]
}; };
//订阅公共事件回调 //订阅公共事件回调
function SubscribeCallBack(err, data) { function subscribeCallBack(err, data) {
if (err) { if (err) {
console.info("subscribe failed " + JSON.stringify(err)); console.info("subscribe failed " + JSON.stringify(err));
} else { } else {
...@@ -571,7 +571,7 @@ function SubscribeCallBack(err, data) { ...@@ -571,7 +571,7 @@ function SubscribeCallBack(err, data) {
} }
} }
//创建订阅者回调 //创建订阅者回调
function CreateSubscriberCallBack(err, commonEventSubscriber) { function createSubscriberCallBack(err, commonEventSubscriber) {
if (err) { if (err) {
console.info("createSubscriber failed " + JSON.stringify(err)); console.info("createSubscriber failed " + JSON.stringify(err));
} else { } else {
...@@ -579,14 +579,14 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) { ...@@ -579,14 +579,14 @@ function CreateSubscriberCallBack(err, commonEventSubscriber) {
subscriber = commonEventSubscriber; subscriber = commonEventSubscriber;
//订阅公共事件 //订阅公共事件
try { try {
CommonEventManager.subscribe(subscriber, SubscribeCallBack); CommonEventManager.subscribe(subscriber, subscribeCallBack);
} catch(err) { } catch(err) {
console.info("subscribe failed " + JSON.stringify(err)); console.info("subscribe failed " + JSON.stringify(err));
} }
} }
} }
//取消订阅公共事件回调 //取消订阅公共事件回调
function UnsubscribeCallBack(err) { function unsubscribeCallBack(err) {
if (err) { if (err) {
console.info("unsubscribe failed " + JSON.stringify(err)); console.info("unsubscribe failed " + JSON.stringify(err));
} else { } else {
...@@ -595,14 +595,14 @@ function UnsubscribeCallBack(err) { ...@@ -595,14 +595,14 @@ function UnsubscribeCallBack(err) {
} }
//创建订阅者 //创建订阅者
try { try {
CommonEventManager.createSubscriber(subscribeInfo, CreateSubscriberCallBack); CommonEventManager.createSubscriber(subscribeInfo, createSubscriberCallBack);
} catch (err) { } catch (err) {
console.info("createSubscriber failed " + JSON.stringify(err)); console.info("createSubscriber failed " + JSON.stringify(err));
} }
//取消订阅公共事件 //取消订阅公共事件
try { try {
CommonEventManager.unsubscribe(subscriber, UnsubscribeCallBack); CommonEventManager.unsubscribe(subscriber, unsubscribeCallBack);
} catch (err) { } catch (err) {
console.info("unsubscribe failed " + JSON.stringify(err)); console.info("unsubscribe failed " + JSON.stringify(err));
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册