Skip to content

Commit 91e45e7

Browse files
author
Roman Janusz
committed
fixed translation of Publisher<Void> to Task[Unit]
1 parent c5362c8 commit 91e45e7

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

commons-mongo/jvm/src/main/scala/com/avsystem/commons/mongo/typed/TypedClientSession.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@ class TypedClientSession(val nativeSession: ClientSession)
2525
nativeSession.startTransaction(transactionOptions)
2626

2727
def commitTransaction: Task[Unit] =
28-
single(nativeSession.commitTransaction()).void
28+
empty(nativeSession.commitTransaction())
2929

3030
def abortTransaction: Task[Unit] =
31-
single(nativeSession.abortTransaction()).void
31+
empty(nativeSession.abortTransaction())
3232

3333
def inTransaction[T](
3434
transactionOptions: TransactionOptions = TransactionOptions.builder().build()

commons-mongo/jvm/src/main/scala/com/avsystem/commons/mongo/typed/TypedMongoDatabase.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ class TypedMongoDatabase(
3939
//TODO: `runCommand`
4040

4141
def drop: Task[Unit] =
42-
single(optionalizeFirstArg(nativeDatabase.drop(sessionOrNull))).void
42+
empty(optionalizeFirstArg(nativeDatabase.drop(sessionOrNull)))
4343

4444
def listCollectionNames: Observable[String] =
4545
multi(optionalizeFirstArg(nativeDatabase.listCollectionNames(sessionOrNull)))
@@ -54,9 +54,9 @@ class TypedMongoDatabase(
5454
name: String,
5555
setupOptions: CreateCollectionOptions => CreateCollectionOptions = identity,
5656
): Task[Unit] =
57-
single(optionalizeFirstArg(
57+
empty(optionalizeFirstArg(
5858
nativeDatabase.createCollection(sessionOrNull, name, setupOptions(new CreateCollectionOptions))
59-
)).void
59+
))
6060

6161
//TODO: `createView`, `watch`, `aggregate`
6262
}

0 commit comments

Comments
 (0)