SftpOperations - Multiple Read Requests

SftpOperations.scala

def retrieveFileInputStream(name: String,
                            handler: Handler,
                            offset: Long,
                            maxUnconfirmedReads: Int): Try[InputStream] =
  Try {
    val remoteFile = handler.open(name, java.util.EnumSet.of(OpenMode.READ))
    val is = maxUnconfirmedReads match {
      case m if m > 1 =>
        new remoteFile.ReadAheadRemoteFileInputStream(m, offset) {

          override def close(): Unit =
            try {
              super.close()
            } finally {
              remoteFile.close()
            }
        }
      case _ =>
        new remoteFile.RemoteFileInputStream(offset) {

          override def close(): Unit =
            try {
              super.close()
            } finally {
              remoteFile.close()
            }
        }
    }
    Option(is).getOrElse {
      remoteFile.close()
      throw new IOException(s"$name: No such file or directory")
    }
  }