core/src/main/java/com/google/net/stubby/newtransport/okhttp/OkHttpClientTransportFactory.java

package com.google.net.stubby.newtransport.okhttp;

import com.google.common.base.Preconditions;
import com.google.net.stubby.newtransport.ClientTransport;
import com.google.net.stubby.newtransport.ClientTransportFactory;

import java.net.InetSocketAddress;
import java.util.concurrent.ExecutorService;

/**
 * Factory that manufactures instances of {@link OkHttpClientTransport}.
 */
public class OkHttpClientTransportFactory implements ClientTransportFactory {
  private final InetSocketAddress address;
  private final ExecutorService executor;

  public OkHttpClientTransportFactory(InetSocketAddress address, ExecutorService executor) {
    this.address = Preconditions.checkNotNull(address, "address");
    this.executor = Preconditions.checkNotNull(executor, "executor");
  }

  @Override
  public ClientTransport newClientTransport() {
    return new OkHttpClientTransport(address, executor);
  }

}