import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/**
 * Registers handlers for received messages and network status changes with the network of
 * {@code resources}.
 */
private void registerWithNetwork(final SystemResources resources) {
  resources.getNetwork().setListener(new NetworkChannel.NetworkListener() {
    @Override
    public void onMessageReceived(byte[] incomingMessage) {
      InvalidationClientCore.this.handleIncomingMessage(incomingMessage);
    }
    @Override
    public void onOnlineStatusChange(boolean isOnline) {
      InvalidationClientCore.this.handleNetworkStatusChange(isOnline);
    }
    @Override
    public void onAddressChange() {
      // Send a message to the server. The header will include the new network address.
      Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
      sendInfoMessageToServer(false, false);
    }
  });
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/**
 * Registers handlers for received messages and network status changes with the network of
 * {@code resources}.
 */
private void registerWithNetwork(final SystemResources resources) {
  resources.getNetwork().setListener(new NetworkChannel.NetworkListener() {
    @Override
    public void onMessageReceived(byte[] incomingMessage) {
      final String name = "handleIncomingMessage";
      InvalidationClientCore.this.handleIncomingMessage(incomingMessage);
    }
    @Override
    public void onOnlineStatusChange(boolean isOnline) {
      InvalidationClientCore.this.handleNetworkStatusChange(isOnline);
    }
    @Override
    public void onAddressChange() {
      // Send a message to the server. The header will include the new network address.
      Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
      sendInfoMessageToServer(false, false);
    }
  });
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
@Override
public NetworkEndpointId getNetworkIdForTest() {
  NetworkChannel network = resources.getNetwork();
  if (!(network instanceof TestableNetworkChannel)) {
    throw new UnsupportedOperationException(
        "getNetworkIdForTest requires a TestableNetworkChannel, not: " + network.getClass());
  }
  return ((TestableNetworkChannel) network).getNetworkIdForTest();
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/** See specs at {@code DefaultResourcesFactory.createDefaultResourcesBuilder}. */
public SystemResourcesBuilder(Logger logger, Scheduler internalScheduler,
    Scheduler listenerScheduler, NetworkChannel network, Storage storage) {
  this.logger = logger;
  this.internalScheduler = internalScheduler;
  this.listenerScheduler = listenerScheduler;
  this.network = network;
  this.storage = storage;
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/** Creates an instance for test from the provided resources and context. */

AndroidResources(Logger logger, AndroidInternalScheduler internalScheduler,
    NetworkChannel network, Storage storage, Context context) {
  super(logger, internalScheduler, new InvalidScheduler(), network, storage,
      getPlatformString());
  this.context = Preconditions.checkNotNull(context);
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/**
 * Constructs a {@link SystemResourcesBuilder} instance using default scheduling, Android-style
 * logging, and storage, and using {@code network} to send and receive messages.
 */
public static SystemResourcesBuilder createResourcesBuilder(String logPrefix,
    NetworkChannel network, Storage storage) {
  SystemResourcesBuilder builder = new SystemResourcesBuilder(AndroidLogger.forPrefix(logPrefix),
        new ExecutorBasedScheduler("ticl" + logPrefix),
        new ExecutorBasedScheduler("ticl-listener" + logPrefix),
        network, storage);
  builder.setPlatform("Android-" + android.os.Build.VERSION.RELEASE);
  return builder;
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/** Returns the network channel. */
public NetworkChannel getNetwork() {
  return network;
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/**
 * Sets the network channel for communicating with the server to be {@code network}.
 * <p>
 * REQUIRES: {@link #build} has not been called.
 */
public SystemResourcesBuilder setNetwork(NetworkChannel network) {
  Preconditions.checkState(!sealed, "Builder's build method has already been called");
  this.network = network;
  return this;
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/**
 * Sets the network message listener provided by the Ticl. The network calls this method when
 * the Ticl provides it with a listener; the Ticl service later retrieves the listener when
 * it has a network event to communicate to the Ticl.
 */
public void setNetworkListener(NetworkChannel.NetworkListener networkListener) {
  Preconditions.checkState(this.networkListener == null, "Listener already set: %s",
      networkListener);
  this.networkListener = Preconditions.checkNotNull(networkListener);
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
/** Returns the network listener provided by the Ticl. */
NetworkChannel.NetworkListener getNetworkListener() {
  return Preconditions.checkNotNull(networkListener, "network listener not yet set");
}
 

import com.google.ipc.invalidation.external.client.SystemResources.NetworkChannel; //导入依赖的package包/类
@Override
public void setListener(NetworkChannel.NetworkListener listener) {
  this.listener = Preconditions.checkNotNull(listener);
}