Передача потоков в функцию и из нее (данные flutter_libserialport в декодер COBS)

Я пытался заставить работать функцию decodeCOBSStream COBS 0.2.0. Я отправляю данные по Bluetooth-соединению ПК из терминальной программы Hercules (значения HEX с отключенным CR/LF) на модуль Bluetooth HC-05, подключенный к порту USB через кабель FTDI. flutter_libserialport отлично справляется с необработанными значениями, я могу вывести их на консоль отладки, и все выглядит нормально.

Однако когда я пытаюсь передать поток в decodeCOBSStream и распечатать его, первое сообщение печатается нормально. Иногда это делает второй. Затем он перестает печатать сообщения, и в конечном итоге процедура чтения flutter_libserialport выдает исключение в операторе возврата.

ArgumentError (Недопустимый аргумент(ы): длина должна находиться в диапазоне [0, 4611686018427387903].)

Это рассматриваемая функция из flutter_libserialport:

static Uint8List read(int bytes, UtilFunc<ffi.Uint8> readFunc) {
    return ffi.using((arena) {
      final ptr = arena<ffi.Uint8>(bytes);
      final len = call(() => readFunc(ptr));
      return Uint8List.fromList(ptr.asTypedList(len));
    });
  }

Вот мой код. Если я создам список, который отправляет значения, поступающие из предстоящих данных, в onDataReceived (изменив его на использование Uint8List в качестве входных данных), все в порядке. Я почти уверен, что именно так я помещаю decodeCOBSStream между ними. flutter_libserialport работает с Uint8List, а decodeCOBSStream работает с ByteData.

import 'dart:typed_data';
import 'dart:async';
import 'package:flutter/material.dart';
import 'package:flutter_libserialport/flutter_libserialport.dart';
import 'package:cobs2/cobs2.dart';

const kDebugMode = true;

void main() {
  runApp(const MyApp());
}

class MyApp extends StatefulWidget {
  const MyApp({super.key});

  @override
  State<MyApp> createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  @override
  Widget build(BuildContext context) {
    List<String> availablePort = SerialPort.availablePorts;
    SerialPort port = SerialPort('COM4');
    SerialPortReader reader = SerialPortReader(port);
    final controller = StreamController<ByteData>();

    debugPrint('Available Ports: $availablePort');

/*    
    Stream<ByteData> upcomingData = reader.stream.map((data) {
      ByteData byteData = data.buffer.asByteData();
      return byteData;
    });
*/
    // Received the serial data from the SerialPortReader 'reader'
    Stream<Uint8List> upcomingData = reader.stream.map((data) {
      return data;
    });

    controller.addStream(decodeCOBSStream(upcomingData.byteData));

    // When data is received
    void onDataReceived(ByteData data) {
      var decodeUint8 = data.buffer.asUint8List();
      var decodedPrt =
          getHexString(decodeUint8, offset: 0, length: decodeUint8.length);
      debugPrint('Decoded: $decodedPrt');
    }

/*    // When data is received
    void onDataReceived(Uint8List data) {
      var decodedPrt = getHexString(data, offset: 0, length: data.length);
      debugPrint('Decoded: $decodedPrt');
    }
*/
    try {
      port.openReadWrite();
      initSerial(port);

      // Send data to serial port
      serialSend(port, 'Ready for data!');

      // Creates a listener to receive the decoded data
      //controller.stream.listen((data) => onDataReceived(data));
      controller.stream.listen(onDataReceived).onDone(() {});
      //upcomingData.listen(onDataReceived).onDone(() {});
    } on SerialPortError catch (err, _) {
      debugPrint('${SerialPort.lastError}');
      port.close();
    }

    return Container();
  }
}

extension on Stream<Uint8List> {
  Stream<ByteData> get byteData => transform(Uint8ListToByteData());
}

// Stream transformer that converts Uint8List data to ByteData.
class Uint8ListToByteData extends StreamTransformerBase<Uint8List, ByteData> {
  @override
  Stream<ByteData> bind(Stream<Uint8List> stream) {
    return stream.map((data) => data.buffer.asByteData());
  }
}

Uint8List _stringToUint8List(String data) {
  List<int> codeUnits = data.codeUnits;
  Uint8List uint8list = Uint8List.fromList(codeUnits);
  return uint8list;
}

// Converts a String of multiple integers into HEX
String getHexString(
  List<int> list, {
  required int offset,
  required int length,
}) {
  var sublist = list.getRange(offset, offset + length);
  return [
    for (var byte in sublist)
      byte.toRadixString(16).padLeft(2, '0').toUpperCase()
  ].join();
}

void initSerial(SerialPort port) {
  var config = port.config;
  config.baudRate = 9600;
  config.bits = 8;
  config.stopBits = 1;
  config.parity = 0;
  port.config = config;

  debugPrint('BaudRate = 9600');
}

void serialSend(SerialPort port, String data) {
  debugPrint('Written Bytes: ${port.write(_stringToUint8List(data))}');
}

Я пробовал передавать данные в flutter_libserialport разными способами. Я попытался изменить его с Uint8List на ByteData в функции предстоящих данных и попытался использовать для этого преобразователи потока. Некоторые из опробованных мной вариантов показаны, но закомментированы.