diff options
| author | Zach Smith <zach@driver.xyz> | 2018-08-01 13:05:56 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-08-01 13:05:56 -0700 |
| commit | 5a48dbf20422537e123e7e0cfddd57570abc3fa4 (patch) | |
| tree | d060c2a2fafb5eb093c4651a86f7f28fc1186b88 /src/main/scala/xyz/driver/core/storage/BlobStorage.scala | |
| parent | e6552f3b31b55396c652c196c5c3a9c3a6cfed71 (diff) | |
| download | driver-core-5a48dbf20422537e123e7e0cfddd57570abc3fa4.tar.gz driver-core-5a48dbf20422537e123e7e0cfddd57570abc3fa4.tar.bz2 driver-core-5a48dbf20422537e123e7e0cfddd57570abc3fa4.zip | |
Add Aliyun OSS blob storage support (#187)
* Add Aliyun OSS blob storage support
* Fix bugs, add convencience constructors, add signed URL support
Diffstat (limited to 'src/main/scala/xyz/driver/core/storage/BlobStorage.scala')
| -rw-r--r-- | src/main/scala/xyz/driver/core/storage/BlobStorage.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/scala/xyz/driver/core/storage/BlobStorage.scala b/src/main/scala/xyz/driver/core/storage/BlobStorage.scala index ee6c5d7..0cde96a 100644 --- a/src/main/scala/xyz/driver/core/storage/BlobStorage.scala +++ b/src/main/scala/xyz/driver/core/storage/BlobStorage.scala @@ -3,9 +3,9 @@ package xyz.driver.core.storage import java.net.URL import java.nio.file.Path +import akka.Done import akka.stream.scaladsl.{Sink, Source} import akka.util.ByteString -import akka.{Done, NotUsed} import scala.concurrent.Future import scala.concurrent.duration.Duration @@ -30,7 +30,7 @@ trait BlobStorage { def content(name: String): Future[Option[Array[Byte]]] /** Stream data asynchronously and with backpressure. */ - def download(name: String): Future[Option[Source[ByteString, NotUsed]]] + def download(name: String): Future[Option[Source[ByteString, Any]]] /** Get a sink to upload data. */ def upload(name: String): Future[Sink[ByteString, Future[Done]]] |