* minor GridFSStreamObserver update

Author: sfxcode

CHANGES.md

@@ -2,9 +2,10 @@
 
 ## Versions
 
-### 1.8.1
+### 1.8.2
 
 * GridFSStreamObserver suports now completed and resultLength
+* implcit resultLength (in bytes) for GridFSStreamObserver
 
 ### 1.8.0
 

src/main/scala/com/sfxcode/nosql/mongo/gridfs/Base.scala

@@ -34,14 +34,15 @@ abstract class Base extends LazyLogging {
 
   def readConcern: ReadConcern = gridfsBucket.readConcern
 
-  def upload(fileName: String,
-             source: Observable[ByteBuffer],
-             metadata: AnyRef = Document(),
-             chunkSizeBytes: Int = 1024 * 256): Observable[ObjectId] = {
+  def upload(
+    fileName: String,
+    source: Observable[ByteBuffer],
+    metadata: AnyRef = Document(),
+    chunkSizeBytes: Int = 1024 * 256): Observable[ObjectId] = {
     val metadataDocument = {
       metadata match {
         case document: Document => document
-        case _                  => Converter.toDocument(metadata)
+        case _ => Converter.toDocument(metadata)
       }
     }
     val options: GridFSUploadOptions = new GridFSUploadOptions()
@@ -55,7 +56,7 @@ abstract class Base extends LazyLogging {
 
   def downloadToStream(oid: ObjectId, outputStream: OutputStream): GridFSStreamObserver = {
     val observable: GridFSDownloadObservable = gridfsBucket.downloadToObservable(oid)
-    val observer                             = GridFSStreamObserver(outputStream)
+    val observer = GridFSStreamObserver(outputStream)
     observable.subscribe(observer)
     observer
   }

src/main/scala/com/sfxcode/nosql/mongo/gridfs/GridFSStreamObserver.scala

@@ -9,7 +9,7 @@ import org.mongodb.scala.Observer
 
 case class GridFSStreamObserver(outputStream: OutputStream) extends Observer[ByteBuffer] with LazyLogging {
   val completed    = new AtomicBoolean(false)
-  val resultLength = new AtomicInteger(0)
+  val resultLength = new AtomicLong(0)
 
   override def onNext(buffer: ByteBuffer): Unit = {
     val bytes = new Array[Byte](buffer.remaining())

src/main/scala/com/sfxcode/nosql/mongo/package.scala

@@ -74,7 +74,7 @@ package object mongo extends ObservableIncludes with ObservableImplicits {
 
   implicit def gridFSFileToBSonIdValue(file: GridFSFile): BsonValue = file.getId
 
-  implicit def observerToResult(observer: GridFSStreamObserver): Int = {
+  implicit def observerToResultLength(observer: GridFSStreamObserver): Long = {
     while (!observer.completed.get) {}
     observer.resultLength.get()
   }

src/test/scala/com/sfxcode/nosql/mongo/gridfs/GridfsDatabase.scala

@@ -5,8 +5,8 @@ import com.sfxcode.nosql.mongo.GridFSDAO
 import com.sfxcode.nosql.mongo.database.DatabaseProvider
 
 /**
-  * GridFS Database Sample
-  */
+ * GridFS Database Sample
+ */
 object GridfsDatabase {
   val SourcePath = "src/test/resources/images/"
   val TargetPath = "/tmp/_files/"

src/test/scala/com/sfxcode/nosql/mongo/gridfs/GridfsDatabaseFunctions.scala

@@ -29,14 +29,13 @@ trait GridfsDatabaseFunctions {
   }
 
   def downloadImage(id: ObjectId, path: String): Unit = {
-    val file      = File(path)
-    val start     = System.currentTimeMillis()
+    val file = File(path)
+    val start = System.currentTimeMillis()
     val size: Int = ImageFilesDAO.downloadToStream(id, file.newOutputStream)
 
     println(
       "file: %s with size %s Bytes written in %s ms "
-        .format(file.pathAsString, size, System.currentTimeMillis() - start)
-    )
+        .format(file.pathAsString, size, System.currentTimeMillis() - start))
   }
 
   def findImage(id: ObjectId): GridFSFile = ImageFilesDAO.findById(id)