Searched refs:prepareOp (Results 1 – 5 of 5) sorted by relevance
56 override fun finishPrepare(prepareOp: PrepareOp) in finishPrepare()64 override fun finishPrepare(prepareOp: PrepareOp) in finishPrepare()74 public abstract fun finishPrepare(prepareOp: PrepareOp) // non-null on failure in prepare()75 public open fun onPrepare(prepareOp: PrepareOp): Any? // non-null on failure in prepare()
329 override fun finishPrepare(prepareOp: PrepareOp) { in <lambda>()333 _affectedNode.compareAndSet(null, prepareOp.affected) in <lambda>()383 override fun finishPrepare(prepareOp: PrepareOp) { in <lambda>()387 _affectedNode.compareAndSet(null, prepareOp.affected) in <lambda>()388 _originalNext.compareAndSet(null, prepareOp.next) in <lambda>()458 public abstract fun finishPrepare(prepareOp: PrepareOp) in <lambda>()461 public open fun onPrepare(prepareOp: PrepareOp): Any? { in <lambda>()462 finishPrepare(prepareOp) in <lambda>()489 val prepareOp = PrepareOp(affected, next as Node, this) in <lambda>() constant490 if (affected._next.compareAndSet(next, prepareOp)) { in <lambda>()[all …]
99 actual override fun finishPrepare(prepareOp: PrepareOp) {} in finishPrepare()111 actual override fun finishPrepare(prepareOp: PrepareOp) {} in onComplete()119 actual abstract fun finishPrepare(prepareOp: PrepareOp) in finishPrepare()122 actual open fun onPrepare(prepareOp: PrepareOp): Any? { in finishPrepare()123 finishPrepare(prepareOp) in finishPrepare()
361 override fun onPrepare(prepareOp: PrepareOp): Any? { in <lambda>()362 val affected = prepareOp.affected as ReceiveOrClosed<E> // see "failure" impl in <lambda>()363 val token = affected.tryResumeReceive(element, prepareOp) ?: return REMOVE_PREPARED in <lambda>()694 override fun onPrepare(prepareOp: PrepareOp): Any? { in iterator()695 val affected = prepareOp.affected as Send // see "failure" impl in iterator()696 val token = affected.tryResumeSend(prepareOp) ?: return REMOVE_PREPARED in iterator()