TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-06-22 02:18:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update scalafmt to 3.0.8

Browse Source
This commit is contained in:
eikek
2021-12-11 20:30:47 +01:00
parent 61379ffff7
commit c21b2cdd29
29 changed files with 42 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/pubsub/naive/src/main/scala/docspell/pubsub/naive/NaivePubSub.scala
View File

@ -80,7 +80,7 @@ final class NaivePubSub[F[_]: Async](
} yield head
def publish(topic: Topic): Pipe[F, Json, MessageHead] =
ms => //TODO Do some optimization by grouping messages to the same topic
ms => // TODO Do some optimization by grouping messages to the same topic
ms.evalMap(publish0(topic, _))
def subscribe(topics: NonEmptyList[Topic]): Stream[F, Message[Json]] =

2
modules/pubsub/naive/src/test/scala/docspell/pubsub/naive/NaivePubSubTest.scala
View File

@ -58,7 +58,7 @@ class NaivePubSubTest extends CatsEffectSuite with Fixtures {
res <- subscribe(ps, Topics.jobSubmitted)
(received, halt, subFiber) = res
_ <- ps.publish1(otherTopic, JobSubmittedMsg("hello".id))
_ <- IO.sleep(100.millis) //allow some time for receiving
_ <- IO.sleep(100.millis) // allow some time for receiving
_ <- halt.set(true)
outcome <- subFiber.join
_ = assert(outcome.isSuccess)