execute method

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

Implementation

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