</BUG>
private Map<String, RpcRequested> providers;
private UtilAckTimeoutRegistry ackTimeoutRegistry;
private UtilResubscribeNotifier resubscribeNotifier;
private Map<String, Rpc> rpcs;
<BUG>RpcHandler( Map options, IConnection connection, IDeepstreamClient client ) {
</BUG>
this.options = options;
this.connection = connection;
this.client = client;

import java.util.Map;
public class RpcHandler implements UtilResubscribeCallback {
private int timeoutDuration;
private Map options;
private IConnection connection;
private DeepstreamClientAbstract client;
private Map<String, RpcRequested> providers;
private UtilAckTimeoutRegistry ackTimeoutRegistry;
private UtilResubscribeNotifier resubscribeNotifier;
private Map<String, Rpc> rpcs;
RpcHandler( Map options, IConnection connection, DeepstreamClientAbstract client ) {
this.options = options;
this.connection = connection;
this.client = client;
