From 0c27c002ccb6e18ff4cccb9e6a523e209d999bda Mon Sep 17 00:00:00 2001 From: Christopher Davenport Date: Tue, 7 Jul 2020 09:15:01 -0700 Subject: [PATCH] Open ReactorCore for Access to Conversion --- core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala b/core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala index 665b2f8..724b2d3 100644 --- a/core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala +++ b/core/src/main/scala/com/banno/cosmos4s/ReactorCore.scala @@ -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)