connectEOM method

dynamic connectEOM(int timeOut, String eom, Function callback, { int attempts = 1, })

Initializes the connection. Socket starts listening to server for data 'callback' function will be called when 'eom' is received

• @param the timeOut amount of time to attempt the connection in milliseconds
• @param the eom sequence of characters at the end of each single message
• @param the callback function called when received a message. It must take a 'String' as param which is the message received
• @param the attempts number of attempts before stop trying to connect. Default is 1

Implementation

connectEOM(int timeOut, String eom,  Function callback, {int attempts=1}) async{

  int k=1;
  while(k<=attempts){
    try{
      _server = await Socket.connect(_ipAddress, _portAddress, timeout: new Duration(milliseconds: timeOut));
      break;
    }catch(exception){
      _printData(k.toString()+" attempt: Socket not connected (Timeout reached)");
      if(k==attempts){
        return;
      }
    }
    k++;
  }
  _connected=true;
  _printData("Socket successfully connected");
  StringBuffer message=new StringBuffer();
  _server!.listen((List<int> event) async {
    String received=(utf8.decode(event));
    message.write(received);
    if(received.contains(eom)){
      _printData("Message received: "+message.toString());

      List<String> messages=message.toString().split(eom);
      if(!received.endsWith(eom)){
        message.clear();
        message.write(messages.last);
        messages.removeLast();
      }
      else{
        message.clear();
      }
      for(String m in messages){
        callback(m);
      }
    }
  });
}