diff options
| author | Jakob Odersky <jakob@driver.xyz> | 2017-07-25 00:16:26 -0700 |
|---|---|---|
| committer | Jakob Odersky <jakob@driver.xyz> | 2017-07-25 00:16:26 -0700 |
| commit | 124fd35527601c61c20f7f9e4a3d099c5e0b883b (patch) | |
| tree | 3e904260f77fbaeb01efa7c4117da4e7eaff95c9 /src/main/scala/xyz/driver/core/file/package.scala | |
| parent | b6fd7800eb503da02ca9724c081b9dd590341bca (diff) | |
| download | driver-core-124fd35527601c61c20f7f9e4a3d099c5e0b883b.tar.gz driver-core-124fd35527601c61c20f7f9e4a3d099c5e0b883b.tar.bz2 driver-core-124fd35527601c61c20f7f9e4a3d099c5e0b883b.zip | |
Add streaming download to file storage.v0.14.0
This enables downloading of content without saving it to a file.
Diffstat (limited to 'src/main/scala/xyz/driver/core/file/package.scala')
| -rw-r--r-- | src/main/scala/xyz/driver/core/file/package.scala | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/core/file/package.scala b/src/main/scala/xyz/driver/core/file/package.scala index b2c679e..dd0998d 100644 --- a/src/main/scala/xyz/driver/core/file/package.scala +++ b/src/main/scala/xyz/driver/core/file/package.scala @@ -10,6 +10,9 @@ import scalaz.{ListT, OptionT} package file { + import akka.NotUsed + import akka.stream.scaladsl.Source + import akka.util.ByteString import java.net.URL import scala.concurrent.duration.Duration @@ -35,6 +38,8 @@ package file { def download(filePath: Path): OptionT[Future, File] + def stream(filePath: Path): OptionT[Future, Source[ByteString, NotUsed]] + def delete(filePath: Path): Future[Unit] /** List contents of a directory */ |