Flutter事件发射器插件typed_event_emitter的使用

typed_event_emitter 是一个简单的 Flutter 包，用于发射和控制事件。通过类型化的事件处理机制，可以更方便地管理不同类型的事件。

使用

要使用 typed_event_emitter 插件，首先需要在 pubspec.yaml 文件中添加依赖：

dependencies:
  typed_event_emitter: ^1.0.0

然后运行以下命令以获取依赖项：

flutter pub get

接下来，您可以参考以下示例代码来了解如何使用该插件。

示例代码

以下是完整的示例代码，展示如何使用 typed_event_emitter 来处理不同类型事件。

示例代码：typed_event_emitter_example.dart

import 'dart:async';
import 'dart:developer';

// 定义事件类
class ServerOnStartEvent {}
class ServerOnStopEvent {}
class ServerOnClientConnectedEvent { final String clientId; ServerOnClientConnectedEvent(this.clientId); }
class ServerOnClientDisconnectedEvent { final String clientId; ServerOnClientDisconnectedEvent(this.clientId); }
class ServerOnErrorEvent { final String message; final dynamic error; final StackTrace stackTrace; ServerOnErrorEvent(this.message, this.error, this.stackTrace); }
class ServerOnDataEvent { final String clientId; final List<int> data; ServerOnDataEvent(this.clientId, this.data); }
class ServerOnSendDataEvent { final List<int> data; ServerOnSendDataEvent(this.data); }

// 定义事件发射器类
class Server extends TypedEventEmitter {
  void start() {
    emit(ServerOnStartEvent());
  }

  void stop() {
    emit(ServerOnStopEvent());
  }

  void addClient(String clientId) {
    emit(ServerOnClientConnectedEvent(clientId));
  }

  void removeClient(String clientId) {
    emit(ServerOnClientDisconnectedEvent(clientId));
  }

  void sendData(List<int> data) {
    emit(ServerOnSendDataEvent(data));
  }

  void handleData(String clientId, List<int> data) {
    emit(ServerOnDataEvent(clientId, data));
  }

  void handleError(String message, dynamic error, StackTrace stackTrace) {
    emit(ServerOnErrorEvent(message, error, stackTrace));
  }
}

void main() {
  // 创建服务器实例
  final server = Server();

  // 注册事件处理器
  server.handle<ServerOnStartEvent>((event) {
    print('Server started');
  });

  server.handle<ServerOnStopEvent>((event) {
    print('Server stopped');
  });

  server.handle<ServerOnClientConnectedEvent>((event) {
    print('client with name "${event.clientId}" was connected');
  });

  server.handle<ServerOnClientDisconnectedEvent>((event) {
    print('client with name "${event.clientId}" was disconnected');
  });

  server.handle<ServerOnErrorEvent>((event) {
    log(event.message, error: event.error, stackTrace: event.stackTrace);
  });

  server.handle<ServerOnDataEvent>((event) {
    print('data received from client "${event.clientId}"');
    print('data: ${String.fromCharCodes(event.data)}');
  });

  server.handle<ServerOnSendDataEvent>((event) {
    print('send data: ${String.fromCharCodes(event.data)}');
  });

  // 启动服务器
  server.start();

  // 添加客户端
  server.addClient('My Client');

  // 模拟发送数据
  server.sendData([72, 101, 108, 108, 111]); // "Hello"

  // 模拟接收数据
  server.handleData('My Client', [72, 101, 108, 108, 111]); // "Hello"

  // 等待一段时间后停止服务器
  Timer(const Duration(seconds: 7), () {
    server.stop();
  });
}

运行效果

运行上述代码后，您将看到以下输出：

Server started
client with name "My Client" was connected
data received from client "My Client"
data: Hello
send data: Hello
Server stopped