corda / net.corda.node.services.messaging / RPCDispatcher / ObservableSerializer / read

read

fun read(kryo: Kryo, input: Input, type: Class<Observable<Any>>): Observable<Any>