open method

@override Future open()

open socket and init stream

Implementation

@override
Future open() async {
  if (_socket != null) {
    throw TTransportError(
        TTransportErrorType.ALREADY_OPEN, "Socket already open");
  }

  if (_host == null) {
    throw TTransportError(
        TTransportErrorType.NOT_OPEN, "Cannot open null host");
  }

  if (_port <= 0) {
    throw TTransportError(
        TTransportErrorType.NOT_OPEN, "Cannot open without port");
  }

  _socket = await Socket.connect(_host!, _port,
      timeout: Duration(milliseconds: _connectionTimeout));
  _initSocket();
}