@Test public void transportDisconnect() { pauseScheduler(); final Connector connector = createConnector(); newConnection( connector ); safeAction( () -> connector.setState( ConnectorState.CONNECTED ) ); connector.transportDisconnect(); verify( connector.getTransport() ).requestDisconnect(); assertEquals( connector.getState(), ConnectorState.DISCONNECTING ); }
@Action void transportDisconnect() { disconnect(); }
Connector extends ReplicantService { @Action void transportDisconnect() { disconnect(); } }
Connector extends ReplicantService { @Action void transportDisconnect() { disconnect(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); }
Connector extends ReplicantService { @Action void transportDisconnect() { disconnect(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString(); }
Connector extends ReplicantService { @Action void transportDisconnect() { disconnect(); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString();  }