public InputStream getInputStream() throws IOException {
    if (!saslClient.isComplete()) {
      throw new IOException("Sasl authentication exchange hasn't completed yet");
    }
    // If Crypto AES is enabled, return cryptoInputStream which unwrap the data with Crypto AES.
    if (cryptoAesEnable && cryptoInputStream != null) {
      return cryptoInputStream;
    }
    return saslInputStream;
  }
Get a SASL wrapped InputStream. Can be called only after saslConnect() has been called.
@return a SASL wrapped InputStream
hbase-client/src/main/java/org/apache/hadoop/hbase/security/HBaseSaslRpcClient.java