part of redux_remote_devtools;

class SocketClusterWrapper {
  Socket _socket;
  Function socketFactory;
  String url;
  SocketClusterWrapper(this.url, {this.socketFactory = Socket.connect});

  Future<void> connect() async {
    this._socket = await socketFactory(this.url);
  }

  Emitter on(String event, Function func) {
    return this._socket.on(event, func);
  }

  void emit(String event, Object data, [AckCall ack]) {
    this._socket.emit(event, data, ack);
  }

  get id => this._socket.id;
}