Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Rework transport and internal implementation to support multiplexed transports #255

Merged
merged 1 commit into from
Oct 21, 2024

Rework transport and internal implementation to support multiplexed t…

0834fbc
Select commit
Loading
Failed to load commit list.
Refresh
Sign in for the full log view
Merged

Rework transport and internal implementation to support multiplexed transports #255

Rework transport and internal implementation to support multiplexed t…
0834fbc
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results failed May 25, 2024 in 0s

1 fail, 575 skipped, 2 841 pass in 46m 31s

  825 files  ±0    825 suites  ±0   46m 31s ⏱️ +19s
3 417 tests ±0  2 841 ✅  - 1    575 💤 ±0  1 ❌ +1 
7 056 runs  ±0  5 851 ✅  - 1  1 204 💤 ±0  1 ❌ +1 

Results for commit 0834fbc. ± Comparison against earlier commit c71adfb.

Annotations

Check warning on line 0 in io.rsocket.kotlin.internal.RSocketRequesterTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 out of 4 runs failed: cancelRequesterToCloseConnection[jvm] (io.rsocket.kotlin.internal.RSocketRequesterTest) 

test-reports/rsocket-core/build/test-results/jvm11Test/TEST-io.rsocket.kotlin.internal.RSocketRequesterTest.xml [took 0s]
Raw output 
app.cash.turbine.TurbineAssertionError: Expected item but found Error(CancellationException)
	at app//app.cash.turbine.TurbineAssertionError$Companion.invoke(TurbineAssertionError.kt:32)
	at app//app.cash.turbine.ChannelKt.unexpectedEvent(channel.kt:253)
	at app//app.cash.turbine.ChannelKt.awaitItem(channel.kt:192)
	at app//app.cash.turbine.ChannelKt$awaitItem$1.invokeSuspend(channel.kt)
	at app//kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at app//kotlinx.coroutines.internal.ScopeCoroutine.afterResume(Scopes.kt:28)
	at app//kotlinx.coroutines.AbstractCoroutine.resumeWith(AbstractCoroutine.kt:99)
	at app//kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at app//kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)
	at app//kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584)
	at app//kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:811)
	at app//kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:715)
	at app//kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:702)
Caused by: java.util.concurrent.CancellationException: Requester cancelled
	at _COROUTINE._BOUNDARY._(CoroutineDebugging.kt:42)
	at kotlinx.coroutines.channels.BufferedChannel$BufferedChannelIterator.onClosedHasNext(BufferedChannel.kt:1643)
	at kotlinx.coroutines.channels.BufferedChannel$BufferedChannelIterator.hasNext(BufferedChannel.kt:1633)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.emitAllImpl$FlowKt__ChannelsKt(Channels.kt:32)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt.access$emitAllImpl$FlowKt__ChannelsKt(Channels.kt:1)
	at kotlinx.coroutines.flow.FlowKt__ChannelsKt$emitAllImpl$1.invokeSuspend(Channels.kt)
Caused by: java.util.concurrent.CancellationException: Requester cancelled
	at kotlinx.coroutines.ExceptionsKt.CancellationException(Exceptions.kt:17)
	at kotlinx.coroutines.JobKt__JobKt.cancel(Job.kt:601)
	at kotlinx.coroutines.JobKt.cancel(Unknown Source)
	at io.rsocket.kotlin.connection.ConnectionEstablishmentHandler.handleConnection$lambda$1(ConnectionEstablishmentHandler.kt:70)
	at kotlinx.coroutines.InternalCompletionHandler$UserSupplied.invoke(CompletionHandler.common.kt:67)
	at kotlinx.coroutines.InvokeOnCompletion.invoke(JobSupport.kt:1392)
	at kotlinx.coroutines.JobSupport.notifyCompletion(JobSupport.kt:1502)
	at kotlinx.coroutines.JobSupport.completeStateFinalization(JobSupport.kt:322)
	at kotlinx.coroutines.JobSupport.finalizeFinishingState(JobSupport.kt:239)
	at kotlinx.coroutines.JobSupport.tryMakeCompletingSlowPath(JobSupport.kt:917)
	at kotlinx.coroutines.JobSupport.tryMakeCompleting(JobSupport.kt:874)
	at kotlinx.coroutines.JobSupport.cancelMakeCompleting(JobSupport.kt:707)
	at kotlinx.coroutines.JobSupport.cancelImpl$kotlinx_coroutines_core(JobSupport.kt:678)
	at kotlinx.coroutines.JobSupport.cancelInternal(JobSupport.kt:643)
	at kotlinx.coroutines.JobSupport.cancel(JobSupport.kt:628)
	at kotlinx.coroutines.CoroutineScopeKt.cancel(CoroutineScope.kt:284)
	at kotlinx.coroutines.CoroutineScopeKt.cancel$default(CoroutineScope.kt:282)
	at io.rsocket.kotlin.internal.RSocketRequesterTest$cancelRequesterToCloseConnection$1$1.invokeSuspend(RSocketRequesterTest.kt:415)
	at _COROUTINE._BOUNDARY._(CoroutineDebugging.kt:42)
	at io.rsocket.kotlin.TestConnection$connectClient$1.invokeSuspend(TestConnection.kt:48)
Caused by: java.util.concurrent.CancellationException: Requester cancelled
	at kotlinx.coroutines.ExceptionsKt.CancellationException(Exceptions.kt:17)
	at kotlinx.coroutines.JobKt__JobKt.cancel(Job.kt:601)
	at kotlinx.coroutines.JobKt.cancel(Unknown Source)
	at io.rsocket.kotlin.connection.ConnectionEstablishmentHandler.handleConnection$lambda$1(ConnectionEstablishmentHandler.kt:70)
	at kotlinx.coroutines.InternalCompletionHandler$UserSupplied.invoke(CompletionHandler.common.kt:67)
	at kotlinx.coroutines.InvokeOnCompletion.invoke(JobSupport.kt:1392)
	at kotlinx.coroutines.JobSupport.notifyCompletion(JobSupport.kt:1502)
	at kotlinx.coroutines.JobSupport.completeStateFinalization(JobSupport.kt:322)
	at kotlinx.coroutines.JobSupport.finalizeFinishingState(JobSupport.kt:239)
	at kotlinx.coroutines.JobSupport.tryMakeCompletingSlowPath(JobSupport.kt:917)
	at kotlinx.coroutines.JobSupport.tryMakeCompleting(JobSupport.kt:874)
	at kotlinx.coroutines.JobSupport.cancelMakeCompleting(JobSupport.kt:707)
	at kotlinx.coroutines.JobSupport.cancelImpl$kotlinx_coroutines_core(JobSupport.kt:678)
	at kotlinx.coroutines.JobSupport.cancelInternal(JobSupport.kt:643)
	at kotlinx.coroutines.JobSupport.cancel(JobSupport.kt:628)
	at kotlinx.coroutines.CoroutineScopeKt.cancel(CoroutineScope.kt:284)
	at kotlinx.coroutines.CoroutineScopeKt.cancel$default(CoroutineScope.kt:282)
	at io.rsocket.kotlin.internal.RSocketRequesterTest$cancelRequesterToCloseConnection$1$1.invokeSuspend(RSocketRequesterTest.kt:415)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.internal.ScopeCoroutine.afterResume(Scopes.kt:28)
	at kotlinx.coroutines.AbstractCoroutine.resumeWith(AbstractCoroutine.kt:99)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:46)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:811)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:715)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:702)
Caused by: kotlinx.coroutines.JobCancellationException: Job was cancelled; job=SupervisorJobImpl{Cancelled}@f876907
	at app//kotlinx.coroutines.JobSupport.cancel(JobSupport.kt:1556)
	... 12 more
View more details on GitHub Actions