Skip to content
This repository has been archived by the owner on Jul 29, 2024. It is now read-only.

Commit

Permalink
Merge pull request #2 from Banno/openReactorCore
Browse files Browse the repository at this point in the history
  • Loading branch information
JesusMtnez authored Jul 22, 2020
2 parents 3de50fb + 0c27c00 commit 0ea4c35
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ import reactor.core.publisher.Mono
import fs2._
import fs2.interop.reactivestreams._

private[cosmos4s] object ReactorCore {
object ReactorCore {
def monoToEffectOpt[F[_]: ConcurrentEffect: ContextShift, A](m: F[Mono[A]]): F[Option[A]] =
Stream
.eval(m)
Expand Down

0 comments on commit 0ea4c35

Please sign in to comment.