FtpIOGraphStage - Multiple Read Requests

FtpIOGraphStage.scala

protected[this] def doPreStart(): Unit =
  isOpt = ftpLike match {
    case ur: UnconfirmedReads =>
      withUnconfirmedReads(ur)
    case ro: RetrieveOffset =>
      Some(ro.retrieveFileInputStream(path, handler.get.asInstanceOf[ro.Handler], offset).get)
    case _ =>
      Some(ftpLike.retrieveFileInputStream(path, handler.get).get)
  }

private def withUnconfirmedReads(
    ftpLikeWithUnconfirmedReads: FtpLike[FtpClient, S] with UnconfirmedReads
): Option[InputStream] =
  connectionSettings match {
    case s: SftpSettings =>
      Some(
        ftpLikeWithUnconfirmedReads
          .retrieveFileInputStream(path,
                                   handler.get.asInstanceOf[ftpLikeWithUnconfirmedReads.Handler],
                                   offset,
                                   s.maxUnconfirmedReads)
          .get
      )
  }