Estou realizando uma comunicação por socket usando flutter em um equipamento Modbus, preciso enviar várias leituras no equipamento, porém uma sobrepõe a outra antes da resposta do socket anterior. Tentei de várias formas, porém não consigo disparar automaticamente. Apenas em cliques seguidos em um botão. Tentei adicionar um loop. Mas ele só envia várias requisições e só obtém a última resposta. Porém clique a clique funciona. Alguém me ajuda??
Estou utilizando a classe IO do Dart e Flutter.
sleep(const Duration(milliseconds: 300));
Uint8List request = preparaCMDUint8list(counter, 3, 1, '16', null);
await Future.wait([xhandle(request)]).then((_) {
print('acabou o envio $_');
// sleep(const Duration(milliseconds: 200));
// setState(() {});
}).whenComplete(() {});
Uint8List request = preparaCMDUint8list(counter, 3, 1, '17', null);
await Future.wait([xhandle(request)]).then((_) {
print('acabou o envio $_');
// sleep(const Duration(milliseconds: 200));
// setState(() {});
}).whenComplete(() {});
Esta é a função que envia o socket
Future xhandle(Uint8List _request) async {
conectou = false;
await Socket.connect(connectionProvider.getEnderecoIpConnect(),
int.parse(await connectionProvider.getEnderecoPorta()))
.then((Socket sock) {
conectou = true;
_socket = sock;
_socket.listen(_onData,
onError: errorHandler, onDone: doneHandler, cancelOnError: true);
sleep(const Duration(milliseconds: 100));
}).then((_) {
conectou = true;
print('Enviou, then do socket: $_request');
print(_request); // so that your code runs AFTER the TCP/IP connection
// _socket.write(_request);
//counter++;
print('Passou no timer eviou o request');
print(DateTime.now());
sleep(const Duration(milliseconds: 200));
_socket.add(_request);
sleep(const Duration(milliseconds: 400));
_socket.close();
}).whenComplete(() {
if (!conectou) {
conectou = false;
_socket.close();
print('erro do sockets');
sleep(const Duration(milliseconds: 100));
}
});
}
Existem mai funções que acredito não serem necessárias, como a onDone
, onData
e onError
os Sleep são tentativas de demorar o código para uma requisição não engolir a outra