From 05a8f050e3ffa9f07cfa4731bd0b53b95c28ceb7 Mon Sep 17 00:00:00 2001 From: Dimos Raptis Date: Mon, 14 Oct 2019 13:37:40 +0100 Subject: [PATCH] Shortening lines --- .../rpc/src/main/kotlin/net/corda/client/rpc/RPCException.kt | 3 ++- .../net/corda/client/rpc/internal/ReconnectingCordaRPCOps.kt | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/client/rpc/src/main/kotlin/net/corda/client/rpc/RPCException.kt b/client/rpc/src/main/kotlin/net/corda/client/rpc/RPCException.kt index a0124347bf..e1bcdeafaf 100644 --- a/client/rpc/src/main/kotlin/net/corda/client/rpc/RPCException.kt +++ b/client/rpc/src/main/kotlin/net/corda/client/rpc/RPCException.kt @@ -14,7 +14,8 @@ open class RPCException(message: String?, cause: Throwable?) : CordaRuntimeExcep * @param maxNumberOfRetries the number of retries that had been performed. * @param cause the cause of the last failed attempt. */ -class MaxRpcRetryException(maxNumberOfRetries: Int, cause: Throwable?): RPCException("Max number of retries ($maxNumberOfRetries) was reached.", cause) +class MaxRpcRetryException(maxNumberOfRetries: Int, cause: Throwable?): + RPCException("Max number of retries ($maxNumberOfRetries) was reached.", cause) /** * Signals that the underlying [RPCConnection] dropped. diff --git a/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/ReconnectingCordaRPCOps.kt b/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/ReconnectingCordaRPCOps.kt index b2413af23f..af81268a58 100644 --- a/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/ReconnectingCordaRPCOps.kt +++ b/client/rpc/src/main/kotlin/net/corda/client/rpc/internal/ReconnectingCordaRPCOps.kt @@ -300,7 +300,8 @@ class ReconnectingCordaRPCOps private constructor( return when (method.returnType) { DataFeed::class.java -> { // Intercept the data feed methods and return a ReconnectingObservable instance - val initialFeed: DataFeed = uncheckedCast(doInvoke(method, args, reconnectingRPCConnection.gracefulReconnect.maxRetries)) + val initialFeed: DataFeed = uncheckedCast(doInvoke(method, args, + reconnectingRPCConnection.gracefulReconnect.maxRetries)) val observable = ReconnectingObservable(reconnectingRPCConnection, initialFeed) { // This handles reconnecting and creates new feeds. uncheckedCast(this.invoke(reconnectingRPCConnection.proxy, method, args))