нет

ну код покажите

void initCommandsHandler() async{
   Log.debug(tag, 'initCommandsHandler');
   bleCommandStreamSub = bleCommandStream.asyncMap((command)async{
     if (command != null) {
       Log.debug(tag, 'New commands added $command');
      return await _sendCommandHandler(command);
     }
   }).listen((command) async {
     Log.debug(tag, 'New commands handled $command');
   });
 }

во-первых уберите ненужные асинки
они тут нигде не нужны

Можно какой-нибудь bool добавить isProccessing и если true, то не обрабатывать, а в конце асинхронного ставить его false

Вроде так:
 void initCommandsHandler() async {
   Log.debug(tag, 'initCommandsHandler');
   bleCommandStreamSub = bleCommandStream.asyncMap((command) {
     if (command != null) {
       Log.debug(tag, 'New commands added $command');
       return _sendCommandHandler(command);
     }
   }).listen((command) {
     Log.debug(tag, 'New commands handled $command');
   });
 }

в самой первой строке тоже

он вообще void

расскажите дурочку как включить нулл сафети в новом проекте?

прочел тут что доступны в дарт 2.12 у меня 2.12.3 и флаттере 2 у меня 2.0.6

не фига по дефолту нет нулл сафети)

https://flutter.dev/docs/null-safety

либо пишите Future<void> либо не пишите async

ты прав, но оно не на что не влияет

Никто?(

во-вторых уверены ли вы что _sendCommandHandler не зацикливается нигде?

Вопрос по поводу         return _sendCommandHandler(command);

ну покажите _sendCommandHandler

как флаттер знает, что нужно ждать выполнения?

2.12 именно в pubspec.yaml прописан?

флаттер знает.

Future<BleCommandItemModel> _sendCommandHandler(BleCommandItemModel command) async {
   Log.info(tag, "try to send command $command");

   if (connectionState == PeripheralConnectionState.connected) {
     final currentTime = DateTime.now().millisecondsSinceEpoch;
     BleCommandItemModel finalCommand;

     // Add relevant timestamps to the command
     if (command.firstSendTime == 0) {
       finalCommand = command.copyWith(
         firstSendTime: currentTime,
         lastAttemptToSendTime: currentTime,
       );
     } else {
       finalCommand = command.copyWith(
         lastAttemptToSendTime: currentTime,
       );
     }

     final pck = CommandPacketModel(finalCommand);
     final commandPacket = pck.prepare();
     Log.info(tag, 'commandPacket $commandPacket');

     final chunks = getSplitPacketBytes(commandPacket);
     Log.info(tag, 'chunks $chunks');
     for (final chunk in chunks) {
       Log.info(tag, 'TRY TO WRITE CHUNK $chunk');
       await bleService.writeCharacteristic(chunk);
     }
   } else {
     if (command.onError != null) {
       command.onError!();
     }
     if (commonErrorCallback != null) {
       commonErrorCallback!();
       commonErrorCallback = null;
     }
     Log.warning(tag, "device disconnected, command not sent ");
   }

   return command;
 }