flutter EventBus

Define this eventbus Tools
You can define events in it

import 'dart:async';

import 'package:event_bus/event_bus.dart';
import 'package:flutter/material.dart';
import 'package:social_im/models/im_customInfo_model.dart';
import 'package:social_im/pages/IMCCalling/ui/base/CallTypes.dart';
import 'package:social_im/pages/IMCCalling/ui/base/CallingScenes.dart';
import 'package:tencent_im_sdk_plugin/models/v2_tim_conversation.dart';

class EventBusUtil {
    
  static EventBus? _eventBus;

  // Access to the singleton 
  static EventBus getInstance() {
    
    if (_eventBus == null) {
    
      _eventBus = EventBus();
    }
    return _eventBus!;
  }

  // Return the subscriber of an event 
  static StreamSubscription<T> listen<T extends Event>(
      Function(T event) onData) {
    
    if (_eventBus == null) {
    
      _eventBus = EventBus();
    }
    // The internal stream belongs to broadcast mode , There can be multiple subscribers 
    return _eventBus!.on<T>().listen(onData);
  }

  // Send events 
  static void fire<T extends Event>(T e) {
    
    if (_eventBus == null) {
    
      _eventBus = EventBus();
    }
    _eventBus!.fire(e);
  }
}

abstract class Event {
    }

class LoginEvent extends Event {
    
  static int eventIn = 1;
  static int eventOut = 0;
  static int onKickedOffline = 2;
  static int onUserSigExpired = 3;
  final int status;

  LoginEvent(this.status);
}

class LoginSuccessdEvent extends Event {
    }

class MomentListEvent extends Event {
    }

class ObtainingLocationPermissionEvent extends Event {
    }

class PhotoListEvent extends Event {
    
  int photoType = 0;

  ///0 Upload  1 Delete 

  PhotoListEvent(this.photoType);
}

class PhotoPayEvent extends Event {
    
  int photoId = 0;

  PhotoPayEvent(this.photoId);
}

class VideoListEvent extends Event {
    
  int videoType = 0;

  ///0 Upload  1 Delete 

  VideoListEvent(this.videoType);
}

class VideoPayEvent extends Event {
    
  int videoId = 0;

  VideoPayEvent(this.videoId);
}

class StowKeyboardEvent extends Event {
    }

class MomentEvent extends Event {
    
  final bool? isLike;
  final int? commentCount;
  final int? likeCount;

  MomentEvent({
    this.isLike, this.commentCount, this.likeCount});
}

class MessageNoticeEvent extends Event {
    
  final int? messageType;
  final int? messageNum;
  final int? activityType;

  MessageNoticeEvent({
    this.messageType, this.messageNum,this.activityType});
}

class MessageEvent extends Event {
    
  final V2TimConversation v2timConversation;

  MessageEvent({
    required this.v2timConversation});
}

class CallingVideoEvent extends Event {
    
  final CallingScenes callingVideoType;

  CallingVideoEvent({
    required this.callingVideoType});
}

class ScreeningNearbyEvent extends Event {
    
  RangeValues? rangeValues;
  int? checkType;

  ScreeningNearbyEvent({
    this.rangeValues, this.checkType});
}

class ImCustomInfoEvent extends Event {
    
  ImCustomInfoModel? imCustomInfoModel;

  ImCustomInfoEvent(this.imCustomInfoModel);
}

class MatchDialogEvent extends Event {
    
  int matchType;
  int matchUserId;
  int playType;

  MatchDialogEvent(this.matchType, this.matchUserId, this.playType);
}

class MatchPayNumDialogEvent extends Event {
    
  Map<String, dynamic> payData;

  MatchPayNumDialogEvent(this.payData);
}

class ShakeCloseDialogEvent extends Event{
    
  bool isClose;

  ShakeCloseDialogEvent(this.isClose);
}

class IsCanShakeEvent extends Event{
    
  bool isCanShake;
  IsCanShakeEvent(this.isCanShake);
}

Use ：
Publisher

// If the threshold is reached ,EventBus Release the news , Let the result pop up and return to the interface , Shake it again 
          EventBusUtil.fire(ShakeCloseDialogEvent(true));

subscriber

late StreamSubscription<ShakeCloseDialogEvent> _shakeCloseDialogEvent;

  @override
  void initState() {
    
    // TODO: implement initState
    _shakeCloseDialogEvent = EventBusUtil.listen((event) {
    // Keep monitoring , If you receive true Return to the interface 
      if (event.isClose) {
    
        Navigator.pop(context, true);
      }
    });
    super.initState();
  }

  @override
  void dispose() {
    
    // TODO: implement dispose
    _shakeCloseDialogEvent.cancel();// Cancel 
    super.dispose();
  }