clean method

Implementation

Stream<Es> clean() {
  final action = PathAction.clean.name, chk = 'validator';
  argErr ??= validator();
  if (argErr!.isNotEmpty) throw ArgumentError.value(argErr, action, chk);

  final fields = fieldsFromOptions(fmtFields);
  final fseType = FileSystemEntityType.file;

  final stream = scEntity.stream;
  final fStream =
      stream.where((event) => event.fs.type == fseType).asBroadcastStream();
  late StreamSubscription subs;
  subs = fStream.listen(
    (event) {
      final (entity, stat, extra) = event.asRecord;
      var ok = false;
      try {
        entity.deleteSync();
        ok = true;
      } catch (e, s) {
        logger.stderr('e, $action, data, delete ${entity.path}');
        scEntity.addError(e, s);
      }

      final line =
          Formatter(entity, stat, extra, action, shows: fields, ok: ok);
      logger.stdout(line.toString());
    },
    cancelOnError: cancelOnError,
    onDone: () => logger.trace('d, $action, done.'),
    onError: (e, s) {
      if (cancelOnError) {
        exitCode = ExitCodeExt.error.code;
        subs.cancel();
      }

      logger
        ..trace('d, $action, cancelOnError:$cancelOnError')
        ..stderr('e, $action, error. $e')
        ..stderr(kIsDebug ? '$s' : '');
    }, // onError
  );
  return fStream;
}