如何封装一个通用的commonEvent工具类？

【问题描述】

封装一个通用的commonEvent工具类：希望在创建订阅者的同时注册一个自定义的回调函数，然后在收到事件通知的同时能调用这个自定义的回调函数。

【运行环境】

ROM: 3.2 Beta5； API 9

你好兄弟 ，我项目中的封装。

1. import commonEvent from '@ohos.commonEventManager';
   
2. 
   
3. export class SubscribeEvent {
   
4.   private static subscriber = null
   
5.   // 自定义的回调函数变量
   
6.   private static callback = null
   
7.   /**
   
8.    * 创建订阅者
   
9.    * @param subscribeInfo 订阅事件
   
10.    * @callback 用户自定义回调函数
    
11.    */
    
12.   static createSubscriber(subscribeInfo, callback:(a,b)=>void) {
    
13.     this.callback = callback
    
14.     commonEvent.createSubscriber(subscribeInfo, (err, subscriber) => {
    
15.       if (err) {
    
16.         console.error('CreateSubscriberCallBack err = ' + JSON.stringify(err))
    
17.       } else {
    
18.         this.subscriber = subscriber;
    
19.         this.subscribe(this.subscriber)
    
20.         console.info('Create subscriber succeed')
    
21.       }
    
22.     })
    
23.   }
    
24. 
    
25.   /**
    
26.    * 订阅公共事件
    
27.    * @param subscriber 订阅者
    
28.    */
    
29.   private static subscribe(subscriber) {
    
30.     if (subscriber != null) {
    
31.       commonEvent.subscribe(subscriber, (err, data) => {
    
32.         if (err) {
    
33.           console.error('subscribe err = ' + JSON.stringify(err))
    
34.         } else {
    
35.           console.info('SubscribeCallBack data= ' + JSON.stringify(data))
    
36.           this.callback('hello callback', data)
    
37.         }
    
38.       })
    
39.     } else {
    
40.       console.info("Need create subscriber")
    
41.     }
    
42.   }
    
43. }
    
44. 
    
45. @Entry
    
46. @Component
    
47. struct Faq10_1 {
    
48.   @State message: string = ''
    
49. 
    
50.   build() {
    
51.     Row() {
    
52.       Column() {
    
53.         Text('订阅：' + this.message)
    
54.           .fontSize(30)
    
55.           .fontWeight(FontWeight.Bold)
    
56.           .onClick(() => {
    
57.             let subscribeInfo = {
    
58.               events: ["myEvent"]
    
59.             };
    
60.             let callback = (a,b) => {
    
61.               this.message = a
    
62.             }
    
63.             SubscribeEvent.createSubscriber(subscribeInfo,callback)
    
64.           })
    
65.         Text('发布')
    
66.           .fontSize(30)
    
67.           .fontWeight(FontWeight.Bold)
    
68.           .onClick(() => {
    
69.             //公共事件相关信息
    
70.             let options = {
    
71.               code: 0,    //公共事件的初始代码
    
72.               data: "initial data",//公共事件的初始数据
    
73.               isOrdered: true  //有序公共事件
    
74.             }
    
75.             //发布公共事件回调
    
76.             function publishCB(err) {
    
77.               if (err) {
    
78.                 console.error(`publish failed, code is ${err.code}, message is ${err.message}`);
    
79.               } else {
    
80.                 console.info("publish");
    
81.               }
    
82.             }
    
83.             //发布公共事件
    
84.             try {
    
85.               commonEvent.publish("myEvent", options, publishCB);
    
86.             } catch (err) {
    
87.               console.error(`publish failed, code is ${err.code}, message is ${err.message}`);
    
88.             }
    
89.           })
    
90.       }
    
91.       .width('100%')
    
92.     }
    
93.     .height('100%')
    
94.   }
    
95. }
    

复制代码