set the channel description: RSocket for reactive

set the channel topic: https://rsocket.io/

Greetings. I want to send some specific

config

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?

Is there any plan to implement rsocket-rpc within the rsocket-kotlin framework? Ideally with some kind of pluggable serialization layer that defaults to kotlinx-serialization.

Rsocket is supposed to be bidirectional right? In kotlin-rsocket, I'm not seeing any methods like

requestResponse

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?

Hello guys, as im reading the docs and using at the same time the kotlin-rsocket-impl, i have a question. I do not really get why in the channel api there is an

initPayload: 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 🙂

Hello guys, what is the recommended approach to implement a clientStreamingServer interaction in rsocket-kotlin lib? . I was using before the spring's abstraction and i always thought it was just using the channel one, but as i see now the channel requires from the server to at least return something. My guess here is, that it is ok to just return an empty payload, and for the client to just ignore it?

Hi folks, im using the kotlin-rsocket impl client to connect to a springboot-server (which is using the java-rsocket impl). Since it is a protocol, i guess it should fine, even if im using two different impls. Im getting an error about no destination handler:

io.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 🙂

Each time a client disconnects I get this message that is flooding my logs. Any idea how I can ignore it?

Caused 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)

Hi, I have a problem when trying to use server as requester. Maybe I'm configuring it all wrong (rsocket-kotlin as ktor plugin), but I get error:

Exception 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)