(clientId, request)
| 1121 | }) |
| 1122 | if ( |
| 1123 | options?.retryTransientErrors && hasError && |
| 1124 | error.success.reason._tag === "SocketOpenError" |
| 1125 | ) { |
| 1126 | return (options.onTransientError?.(rpcError) ?? Effect.void).pipe( |
| 1127 | Effect.ignoreCause({ |
| 1128 | log: true, |
| 1129 | message: "RpcClient onTransientError hook failed" |
| 1130 | }) |
| 1131 | ) |
| 1132 | } |
| 1133 | return broadcastError(rpcError) |
| 1134 | }), |
| 1135 | Effect.retryOrElse( |
| 1136 | options?.retryPolicy ?? defaultRetryPolicy, |