jdemeulenaere
12/15/2024, 2:23 PMFlow<Int>
as a parameter of an RPC but it fails with:
Exception in thread "main" kotlinx.serialization.SerializationException: Serializer for subclass 'SafeFlow' is not found in the polymorphic scope of 'Flow'.
Check if class with serial name 'SafeFlow' exists and serializer is registered in a corresponding SerializersModule.
To be registered automatically, class 'SafeFlow' has to be '@Serializable', and the base class 'Flow' has to be sealed and '@Serializable'.
Any idea what I need to do to make it work? It reproduces even with this sample service:
@Rpc
interface ExampleService : RemoteService {
suspend fun multiply(bar: Flow<Int>): Flow<Int>
}
I'm using krpc 0.4.0.jdemeulenaere
12/15/2024, 2:38 PM@Contextual
annotation to make it workjdemeulenaere
12/15/2024, 2:39 PMAlexander Sysoev
01/09/2025, 7:45 AMAlexander Sysoev
01/13/2025, 5:07 PM