debop
12/15/2020, 6:16 AMdebop
12/15/2020, 6:16 AMdebop
02/17/2021, 7:07 AMdebop
02/17/2021, 7:08 AMrcd27
04/09/2022, 10:03 AMconfig
to backend at the start of whole rsocket
interaction. It affects buisness logic, so I want to do it in better way. Now I just put that in setupPayload
, but saw function metadataPush
in RSocket
class. Seems like this is something I need. Any details about it, guys?rocketraman
05/16/2022, 10:13 PMrocketraman
06/08/2022, 2:25 PMrequestResponse
on RSocketServer
.
I thought potentially I would create a single Transport
and then use it to configure both a ConnectionAcceptor
for the server as well as attach it to an RSocketConnector
. However, since we have different ServerTransport
and ClientTransport
types, this doesn't seem possible either.
What am I missing?George
06/23/2022, 3:20 PMinitPayload: Payload
and as second argument the flow. If i need only the flow payload should i just fill it with Payload.Empty
the init? Thanks in advance for anyone who can point me to the right direction 🙂George
06/24/2022, 12:52 PMGeorge
08/24/2022, 3:48 PMio.rsocket.kotlin.RSocketError$ApplicationError: No handler for destination
. So im investigation a bit the spring code and i figured the routing-metada are not decoded properly, also i turned up the debugger in spring and it confirmed it for me after this: DefaultMetadataExtractor : Values extracted from metadata: {} with registrations for [].
So anyone has any ideas? Thanks in advance 🙂Mihai Voicescu
09/27/2022, 8:00 AMCaused by: kotlinx.coroutines.channels.ClosedReceiveChannelException: Channel was closed
at kotlinx.coroutines.channels.Closed.getReceiveException(AbstractChannel.kt:1108)
at kotlinx.coroutines.channels.AbstractChannel$ReceiveElement.resumeReceiveClosed(AbstractChannel.kt:913)
at kotlinx.coroutines.channels.AbstractSendChannel.helpClose(AbstractChannel.kt:342)
at kotlinx.coroutines.channels.AbstractSendChannel.close(AbstractChannel.kt:271)
at kotlinx.coroutines.channels.SendChannel$DefaultImpls.close$default(Channel.kt:93)
at io.ktor.websocket.DefaultWebSocketSessionImpl$runIncomingProcessor$1.invokeSuspend(DefaultWebSocketSession.kt:204)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTaskKt.resume(DispatchedTask.kt:234)
at kotlinx.coroutines.DispatchedTaskKt.resumeUnconfined(DispatchedTask.kt:190)
at kotlinx.coroutines.DispatchedTaskKt.dispatch(DispatchedTask.kt:161)
at kotlinx.coroutines.CancellableContinuationImpl.dispatchResume(CancellableContinuationImpl.kt:397)
at kotlinx.coroutines.CancellableContinuationImpl.completeResume(CancellableContinuationImpl.kt:513)
at kotlinx.coroutines.channels.AbstractChannel$ReceiveHasNext.completeResumeReceive(AbstractChannel.kt:947)
at kotlinx.coroutines.channels.AbstractSendChannel.offerInternal(AbstractChannel.kt:56)
at kotlinx.coroutines.channels.AbstractSendChannel.send(AbstractChannel.kt:134)
at io.ktor.websocket.RawWebSocketJvm$1.invokeSuspend(RawWebSocketJvm.kt:68)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
at kotlinx.coroutines.internal.LimitedDispatcher.run(LimitedDispatcher.kt:42)
at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:95)
at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:750)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664)
langara
06/01/2023, 4:39 PMException in thread "AWT-EventQueue-0 @coroutine#2874" kotlin.NotImplementedError: Request Response is not implemented.
at io.rsocket.kotlin.RSocketKt.notImplemented(RSocket.kt:52)
at io.rsocket.kotlin.RSocketKt.access$notImplemented(RSocket.kt:1)
at io.rsocket.kotlin.RSocket$DefaultImpls.requestResponse(RSocket.kt:38)
at io.rsocket.kotlin.RSocketRequestHandler.requestResponse(RSocketRequestHandler.kt:94)