override fun onNext()

in plugin-azure-server/src/main/kotlin/jetbrains/buildServer/clouds/azure/arm/utils/AzureSdkExtensions.kt [44:61]

• 17 lines of code
• 5 McCabe index (conditional complexity)

        override fun onNext(t: T) {
            if (completed) {
                if (cont.isActive) {
                    cont.resumeWithException(IllegalStateException("Received onNext call after completion"))
                }
                return
            }

            if (seenValue) {
                if (cont.isActive) {
                    cont.resumeWithException(IllegalArgumentException("More than one onNext call"))
                }
                subscription.unsubscribe()
            } else {
                value = t
                seenValue = true
            }
        }