Skip to content

Instantly share code, notes, and snippets.

@conorgriffin
Created February 22, 2021 14:49
Show Gist options
  • Save conorgriffin/1c49c55fcb66f4be2500da15d00e5af4 to your computer and use it in GitHub Desktop.
Save conorgriffin/1c49c55fcb66f4be2500da15d00e5af4 to your computer and use it in GitHub Desktop.
FtpIOGraphStage - Single Read Request
protected[this] def doPreStart(): Unit =
isOpt = ftpLike match {
case ro: RetrieveOffset =>
Some(ro.retrieveFileInputStream(path, handler.get.asInstanceOf[ro.Handler], offset).get)
case _ =>
Some(ftpLike.retrieveFileInputStream(path, handler.get).get)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment