Fix issue SuspendConnection (#191)

Co-authored-by: Rachel M. Carmena <rachelcarmena@users.noreply.github.com>

.github/workflows/build_arrow-fx.yml

@@ -16,20 +16,14 @@ jobs:
     - uses: actions/checkout@v1
     - name: Validate Gradle Wrapper
       uses: gradle/wrapper-validation-action@v1
-    - name: Cache management
-      uses: actions/cache@v2
-      with:
-        path: ~/.gradle/caches
-        key: ${{ runner.os }}--gradle--${{ hashFiles('**/*.gradle*') }}
-        restore-keys: |
-          ${{ runner.os }}--gradle--
     - name: Checkout orchestrator
       run: |
         cd $BASEDIR
         git clone https://github.com/arrow-kt/arrow.git
     - name: Build with Gradle
       run: |
-        $BASEDIR/arrow/scripts/project-build.sh $ARROW_LIB
+        ./gradlew build
+        #$BASEDIR/arrow/scripts/project-build.sh $ARROW_LIB
     #- name: Run benchmark for master branch
     #  run: |
     #    git checkout master
@@ -44,6 +38,3 @@ jobs:
     #  run: |
     #    export PULL_REQUEST_NUMBER=$(echo $GITHUB_REF | cut -d/ -f3)
     #    ./gradlew :arrow-benchmarks-fx:compareBenchmarksCI
-    - name: Clean SNAPSHOTs
-      run: |
-        find ~/.gradle/caches/ -type d -name "*SNAPSHOT*" -prune -exec rm -rf {} +

arrow-fx-coroutines/src/main/kotlin/arrow/fx/coroutines/SuspendConnection.kt

@@ -3,7 +3,10 @@ package arrow.fx.coroutines
 import kotlinx.atomicfu.AtomicRef
 import kotlinx.atomicfu.atomic
 import kotlin.coroutines.AbstractCoroutineContextElement
+import kotlin.coroutines.Continuation
 import kotlin.coroutines.CoroutineContext
+import kotlin.coroutines.EmptyCoroutineContext
+import kotlin.coroutines.startCoroutine
 
 /**
  * Inline marker to mark a [CancelToken],
@@ -83,7 +86,8 @@ internal sealed class SuspendConnection : AbstractCoroutineContextElement(Suspen
 
     override tailrec fun push(token: CancelToken): Unit = when (val list = state.value) {
       // If connection is already cancelled cancel token immediately.
-      null -> Platform.unsafeRunSync { token.invoke() }
+      null -> token.cancel
+        .startCoroutine(Continuation(EmptyCoroutineContext) { })
       else ->
         if (state.compareAndSet(list, listOf(token) + list)) Unit
         else push(token)

gradle.properties

@@ -5,7 +5,7 @@ SUBPROJECT_CONF=https://raw.githubusercontent.com/arrow-kt/arrow/master/subproje
 DOC_CONF=https://raw.githubusercontent.com/arrow-kt/arrow/master/doc-conf.gradle
 PUBLISH_CONF=https://raw.githubusercontent.com/arrow-kt/arrow/master/publish-conf.gradle
 # Gradle options
-org.gradle.jvmargs=-Xmx7g
+org.gradle.jvmargs=-Xmx4g
 org.gradle.parallel=true
 # Kotlin configuration
 kotlin.incremental=true