Added missing ".transactionally"

tminglei · Aug 9, 2016 · 8afdb6f · 8afdb6f
1 parent ce38f24
commit 8afdb6f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/test/scala/com/github/tminglei/slickpg/lobj/LargeObjectSupportSuite.scala b/core/src/test/scala/com/github/tminglei/slickpg/lobj/LargeObjectSupportSuite.scala
@@ -23,7 +23,7 @@ class LargeObjectSupportSuite extends FunSuite {
     val largeObjectUploadStream = new ByteArrayInputStream(testString.getBytes)
     val uploadAction = driver.buildLargeObjectUploadAction(largeObjectUploadStream)
     val composedAction = uploadAction.flatMap(oid => LargeObjectStreamingDBIOAction(oid))
-    val dbPublisher = db.stream(composedAction)
+    val dbPublisher = db.stream(composedAction.transactionally)
 
     val messageBuffer: StringBuffer = new StringBuffer()
     val f = dbPublisher.foreach(bytes => messageBuffer.append(new String(bytes))).andThen {