We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 402ca6c commit b986ddfCopy full SHA for b986ddf
docs/src/main/scala/ReactiveStreamsDoc.scala
@@ -1,5 +1,6 @@
1
import java.util.concurrent.TimeUnit
2
3
+import com.sfxcode.nosql.MongoImplicits
4
import com.sfxcode.nosql.mongo._
5
import com.sfxcode.nosql.mongo.model.Person
6
import com.sfxcode.nosql.mongo.test.TestDatabase.{ImageFilesDAO, PersonDAO}
@@ -8,7 +9,7 @@ import scala.concurrent.ExecutionContext.Implicits.global
8
9
import scala.concurrent.duration.Duration
10
import scala.concurrent.{Await, Future}
11
-object ReactiveStreamsDoc {
12
+object ReactiveStreamsDoc extends MongoImplicits {
13
14
// #max_wait
15
val listWithCustomMaxWait: List[Person] = PersonDAO.find().resultList(maxWait = 15)
0 commit comments