### Question:
BaseEndpoint implements Endpoint { @Override public EndpointState state() { return state.state(); } BaseEndpoint(final String hostname, final int port, final EventLoopGroup eventLoopGroup,
               final ServiceContext serviceContext, final CircuitBreakerConfig circuitBreakerConfig,
               final ServiceType serviceType, final boolean pipelined); @Override EndpointContext context(); @Override void connect(); @Override void disconnect(); @Override boolean receivedDisconnectSignal(); @Stability.Internal void notifyChannelInactive(); @Override void send(final R request); @Override boolean freeToWrite(); @Override long outstandingRequests(); @Override long lastResponseReceived(); @Stability.Internal void markRequestCompletion(); @Stability.Internal void decrementOutstandingRequests(); @Override @Stability.Internal long lastConnectedAt(); @Override EndpointState state(); @Override Flux<EndpointState> states(); boolean pipelined(); @Override EndpointDiagnostics diagnostics();  }### Answer:
@Test void startDisconnected() { InstrumentedEndpoint endpoint = InstrumentedEndpoint.create(eventLoopGroup, ctx, null); assertEquals(EndpointState.DISCONNECTED, endpoint.state()); }