1 files changed, 12 insertions, 0 deletions
diff --git a/src/main/scala/xyz/driver/core/file/FileSystemStorage.scala b/src/main/scala/xyz/driver/core/file/FileSystemStorage.scala
index fab1307..0d49f2d 100644
--- a/src/main/scala/xyz/driver/core/file/FileSystemStorage.scala
+++ b/src/main/scala/xyz/driver/core/file/FileSystemStorage.scala
@@ -1,5 +1,8 @@
 package xyz.driver.core.file
 
+import akka.NotUsed
+import akka.stream.scaladsl.{FileIO, Source}
+import akka.util.ByteString
 import java.io.File
 import java.nio.file.{Files, Path, Paths}
 
@@ -33,6 +36,15 @@ class FileSystemStorage(executionContext: ExecutionContext) extends FileStorage
       Option(new File(filePath.toString)).filter(file => file.exists() && file.isFile)
     })
 
+  override def stream(filePath: Path): OptionT[Future, Source[ByteString, NotUsed]] =
+    OptionT.optionT(Future {
+      if (Files.exists(filePath)) {
+        Some(FileIO.fromPath(filePath).mapMaterializedValue(_ => NotUsed))
+      } else {
+        None
+      }
+    })
+
   override def delete(filePath: Path): Future[Unit] = Future {
     val file = new File(filePath.toString)
     if (file.delete()) ()