emit method

  1. @override
Future<void> emit(
  1. RpcContext context
)

Send a fire-and-forget event.

Implementation

@override
Future<void> emit(RpcContext context) async {
  final routes = eventRouter[context.message.pattern];
  if (routes == null) {
    return;
  }
  for (final route in routes) {
    await route(context);
  }
}