@Test
public void scheduledExecutorService_default() {
  InProcessServerBuilder builder = InProcessServerBuilder.forName("foo");
  InProcessServer server = builder.buildTransportServer(new ArrayList<Factory>());

  ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool =
      server.getScheduledExecutorServicePool();
  ObjectPool<ScheduledExecutorService> expectedPool =
      SharedResourcePool.forResource(TIMER_SERVICE);

  ScheduledExecutorService expected = expectedPool.getObject();
  ScheduledExecutorService actual = scheduledExecutorServicePool.getObject();
  assertSame(expected, actual);

  expectedPool.returnObject(expected);
  scheduledExecutorServicePool.returnObject(actual);
}
 

@Test
public void scheduledExecutorService_custom() {
  InProcessServerBuilder builder = InProcessServerBuilder.forName("foo");
  ScheduledExecutorService scheduledExecutorService =
      new FakeClock().getScheduledExecutorService();

  InProcessServerBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
  assertSame(builder, builder1);

  InProcessServer server = builder1.buildTransportServer(new ArrayList<Factory>());
  ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool =
      server.getScheduledExecutorServicePool();

  assertSame(scheduledExecutorService, scheduledExecutorServicePool.getObject());

  scheduledExecutorServicePool.returnObject(scheduledExecutorService);
}
 

@Test
public void scheduledExecutorService_default() {
  InProcessServerBuilder builder = InProcessServerBuilder.forName("foo");
  InProcessServer server =
      Iterables.getOnlyElement(builder.buildTransportServers(new ArrayList<Factory>()));

  ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool =
      server.getScheduledExecutorServicePool();
  ObjectPool<ScheduledExecutorService> expectedPool =
      SharedResourcePool.forResource(TIMER_SERVICE);

  ScheduledExecutorService expected = expectedPool.getObject();
  ScheduledExecutorService actual = scheduledExecutorServicePool.getObject();
  assertSame(expected, actual);

  expectedPool.returnObject(expected);
  scheduledExecutorServicePool.returnObject(actual);
}
 

@Test
public void scheduledExecutorService_custom() {
  InProcessServerBuilder builder = InProcessServerBuilder.forName("foo");
  ScheduledExecutorService scheduledExecutorService =
      new FakeClock().getScheduledExecutorService();

  InProcessServerBuilder builder1 = builder.scheduledExecutorService(scheduledExecutorService);
  assertSame(builder, builder1);

  InProcessServer server =
      Iterables.getOnlyElement(builder1.buildTransportServers(new ArrayList<Factory>()));
  ObjectPool<ScheduledExecutorService> scheduledExecutorServicePool =
      server.getScheduledExecutorServicePool();

  assertSame(scheduledExecutorService, scheduledExecutorServicePool.getObject());

  scheduledExecutorServicePool.returnObject(scheduledExecutorService);
}
 

@Test
public void createMultipleServers() {
  builder.addListenAddress(new InetSocketAddress(8081));
  List<NettyServer> servers = builder.buildTransportServers(ImmutableList.<Factory>of());

  Truth.assertThat(servers).hasSize(2);
}
 

/** {@inheritDoc} */
@Override
public AltsServerBuilder addStreamTracerFactory(Factory factory) {
  delegate.addStreamTracerFactory(factory);
  return this;
}
 

@Override
public DropwizardServerBuilder addStreamTracerFactory(final Factory factory) {
    origin.addStreamTracerFactory(factory);
    return this;
}
 

/** {@inheritDoc} */
@Override
public AltsServerBuilder addStreamTracerFactory(Factory factory) {
  delegate.addStreamTracerFactory(factory);
  return this;
}