OpenHarmony开发者论坛

标题: 如何封装一个通用的commonEvent工具类？ [打印本页]
作者: 一只杨    时间: 2023-9-1 11:26
标题: 如何封装一个通用的commonEvent工具类？
[md]【问题描述】

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

【运行环境】

ROM:  3.2 Beta5；  API 9
[/md]
作者: 18219201129    时间: 2023-9-4 09:36
你好兄弟 ，我项目中的封装。
  1. import commonEvent from '@ohos.commonEventManager';

  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.   }

  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. }

  45. @Entry
  46. @Component
  47. struct Faq10_1 {
  48.   @State message: string = ''

  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. }
复制代码




欢迎光临 OpenHarmony开发者论坛 (https://forums.openharmony.cn/) Powered by Discuz! X3.5