execute method

Future execute(
  1. T data, {
  2. String? fragment,
  3. Map<String, String>? arguments,
})
override

Implementation

Future<dynamic> execute(T data, {String? fragment, Map<String, String>? arguments}) async {
  if (maxLen <= _queue.length) {
    _queue.removeFirst();
  }
  _queue.add((data, arguments, fragment));
  return _bus.send<T>(data, path: _path, arguments: arguments, fragment: fragment);
}