SftpOperations - Alpakka Single Read Request

SftpOperations.scala

def retrieveFileInputStream(name: String, handler: Handler, offset: Long): Try[InputStream] =
  Try {
    val remoteFile = handler.open(name, java.util.EnumSet.of(OpenMode.READ))
    val is = 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")
    }
  }