Skip to content

Commit 26f6a71

Browse files
committed
moved zipWithNow to scala-2.12 code
1 parent 2c427e9 commit 26f6a71

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

commons-core/src/main/scala-2.12/com/avsystem/commons/CompatSharedExtensions.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.avsystem.commons
22

33
import com.avsystem.commons.CompatSharedExtensions.FutureCompatOps
4+
import com.avsystem.commons.concurrent.RunNowEC
45

56
trait CompatSharedExtensions {
67
implicit def futureCompatOps[A](fut: Future[A]): FutureCompatOps[A] = new FutureCompatOps(fut)
@@ -9,5 +10,8 @@ trait CompatSharedExtensions {
910
object CompatSharedExtensions {
1011
final class FutureCompatOps[A](private val fut: Future[A]) extends AnyVal {
1112
def transformTry[S](f: Try[A] => Try[S])(implicit ec: ExecutionContext): Future[S] = fut.transform(f)
13+
14+
def zipWithNow[B, R](that: Future[B])(f: (A, B) => R): Future[R] =
15+
fut.zipWith(that)(f)(RunNowEC)
1216
}
1317
}

commons-core/src/main/scala/com/avsystem/commons/SharedExtensions.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -238,9 +238,6 @@ object SharedExtensions extends SharedExtensions {
238238
def recoverWithNow[B >: A](pf: PartialFunction[Throwable, Future[B]]): Future[B] =
239239
fut.recoverWith(pf)(RunNowEC)
240240

241-
def zipWithNow[B, R](that: Future[B])(f: (A, B) => R): Future[R] =
242-
fut.zipWith(that)(f)(RunNowEC)
243-
244241
def toUnit: Future[Unit] =
245242
mapNow(_ => ())
246243

0 commit comments

Comments
 (0)