more startF -> startFiber fixes

arrow-kt · Feb 3, 2019 · ab0943e · ab0943e
1 parent d28c514
commit ab0943e
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/modules/docs/arrow-docs/docs/docs/effects/fiber/README.MD b/modules/docs/arrow-docs/docs/docs/effects/fiber/README.MD
@@ -26,9 +26,9 @@ fun <A, B, C> parallelMap(first: IO<A>,
                      second: IO<B>,
                      f: (A, B) -> C): IO<C> =
   fx {
-    val (fiberOne: Fiber<ForIO, A>) = first.startF(Default)
-    val (fiberTwo: Fiber<ForIO, B>) = second.startF(Default)
-    f(fiberOne.join.bind(), fiberTwo.join.bind())
+    val (fiberOne: Fiber<ForIO, A>) = Default.startfiber(first)
+    val (fiberTwo: Fiber<ForIO, B>) = Default.startFiber(second)
+    f(!fiberOne.join, !fiberTwo.join)
   }
 
 val first = IO.sleep(5000).map {
@@ -57,8 +57,8 @@ which allows us to register an operation to run on cancelation, error or complet
 fun <A, B, C> parallelMap2(first: IO<A>,
                           second: IO<B>,
                           f: (A, B) -> C): IO<C> =
-      first.startF(Default).bracket(use = { (joinA, _) ->
-          second.startF(Default).bracket(use = { (joinB, _) ->
+      Default.startFiber(first).bracket(use = { (joinA, _) ->
+          Default.startFiber(second).bracket(use = { (joinB, _) ->
             joinA.flatMap { a ->
               joinB.map { b -> f(a, b) }
             }

diff --git a/modules/effects/arrow-effects-data/src/main/kotlin/arrow/effects/IOStart.kt b/modules/effects/arrow-effects-data/src/main/kotlin/arrow/effects/IOStart.kt
@@ -25,7 +25,7 @@ import kotlin.coroutines.suspendCoroutine
  *   //sampleStart
  *   binding {
  *     val promise = Promise.uncancelable<ForIO, Int>(IO.async()).bind()
- *     val fiber = promise.get().startF(Dispatchers.Default).bind()
+ *     val fiber = Dispatchers.Default.startFiber(promise.get()).bind()
  *     promise.complete(1).bind()
  *     fiber.join().bind()
  *   }.unsafeRunSync() == 1

diff --git a/modules/effects/arrow-effects-data/src/main/kotlin/arrow/effects/typeclasses/Concurrent.kt b/modules/effects/arrow-effects-data/src/main/kotlin/arrow/effects/typeclasses/Concurrent.kt
@@ -145,7 +145,7 @@ interface Concurrent<F> : Async<F> {
    *   //sampleStart
    *   binding {
    *     val promise = Promise.uncancelable<ForIO, Int>(IO.async()).bind()
-   *     val fiber = promise.get().startF(Dispatchers.Default).bind()
+   *     val fiber = Dispatchers.Default.startFiber(promise.get()).bind()
    *     promise.complete(1).bind()
    *     fiber.join().bind()
    *   }.unsafeRunSync() == 1