services-gateway-benchmarks/src/main/java/io/scalecube/services/benchmarks/gateway/distributed/rsocket/DistributedInfiniteStreamBenchmark.java
/**
   * Main runner.
   *
   * @param args program arguments
   */
Main runner.
@param args program arguments
Main runner . @param args program arguments
public static void main(String[] args) {
    InfiniteStreamScenario.runWith(
        args,
        benchmarkSettings ->
            new DistributedBenchmarkState(
                benchmarkSettings,
                "rsws",
                address ->
                    new RSocketGatewayClient(
                        GatewayClientSettings.builder().address(address).build(),
                        GatewayClientCodecs.RSOCKET_CLIENT_CODEC)));
  }
public static void main ( String [ ] args ) { InfiniteStreamScenario . runWith ( args , benchmarkSettings -> new DistributedBenchmarkState ( benchmarkSettings , "rsws" , address -> new RSocketGatewayClient ( GatewayClientSettings . builder ( ) . address ( address ) . build ( ) , GatewayClientCodecs . RSOCKET_CLIENT_CODEC ) ) ) ; }
Main runner.
Main runner .