handleSseConnection

suspend fun <T, OBJECTS_OUT> handleSseConnection(deSerializer: ObjectDeSerializer, rawOut: SendChannel<String>, serializerOut: KSerializer<OBJECTS_OUT>, service: T, function: suspend T.(SendChannel<OBJECTS_OUT>) -> Unit)(source)

Convenience function for cases were the raw channel works with strings. See the overloaded method for details.


suspend fun <T, RAW_OUT, OBJECTS_OUT> handleSseConnection(deSerializer: ObjectDeSerializer, rawOut: SendChannel<RAW_OUT>, rawOutFromText: (String) -> RAW_OUT, serializerOut: KSerializer<OBJECTS_OUT>, service: T, function: suspend T.(SendChannel<OBJECTS_OUT>) -> Unit)(source)

function receives a SendChannel, from which objects are read, serialized and sent to the client in the form of JSON-RPC calls.

Parameters

deSerializer

used to (de-)serialize objects

rawOut

a channel for outgoing messages

rawOutFromText

a function to convert the JSON-string to an object to be sent via rawOut

service

the receiver to be used when calling function

function

the function to delegate data processing to