send method

Future<void> send({ required List<int> value, Duration durationTimeOut = const Duration(minutes: 1), Duration durationDelay = const Duration(milliseconds: 1), })

Implementation

Future<void> send({
  required List<int> value,
  Duration durationTimeOut = const Duration(minutes: 1),
  Duration durationDelay = const Duration(milliseconds: 1),
}) async {
  DateTime dateTime = DateTime.now().add(durationTimeOut);
  await Future.delayed(durationDelay);
  while (true) {
    await Future.delayed(Duration(microseconds: 10));
    if (dateTime.isBefore(DateTime.now())) {
      throw SocketError({
        "@type": "socketError",
        "message": "send_data_time_out",
        "description": "Send Data time out "
      });
    }

    if (isConnect) {
      break;
    }
  }
  return socket.add(value);
}