SocketServer constructor

SocketServer(
  1. String ip,
  2. int port,
  3. void dataListener(
    1. String data
    )?, {
  4. int keepTime = 5,
})

Implementation

SocketServer(this.ip, this.port, this.dataListener, {this.keepTime = 5}) {
  lastTime = DateTime.now();
  _controller = StreamController<SocketEvent>();
  _controller.stream
      .asyncMap(_eventListen)
      .listen(_eventDone, onError: _eventError)
      .onError(_eventError);
  lastTime = DateTime.now();
  _timer = Timer.periodic(Duration(seconds: keepTime), (timer) {
    Duration duration = DateTime.now().difference(lastTime);
    if (duration.inSeconds > keepTime) {
      _controller.add(CloseEvent(debugMsg: "close timeout"));
    }
  });
  _controller.add(ConnectEvent(debugMsg: "connect init"));
}