import java.util.Map;
public class RpcHandler implements UtilResubscribeCallback {
private int timeoutDuration;
private Map options;
private IConnection connection;
<BUG>private IDeepstreamClient client;
</BUG>
private Map<String, RpcRequested> providers;
private UtilAckTimeoutRegistry ackTimeoutRegistry;
private UtilResubscribeNotifier resubscribeNotifier;

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;
