fixes compilation issues in perf tests

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

benchmarks/src/main/java/io/rsocket/RSocketPerf.java renamed to benchmarks/src/main/java/io/rsocket/core/RSocketPerf.java

@@ -1,5 +1,11 @@
-package io.rsocket;
-
+package io.rsocket.core;
+
+import io.rsocket.AbstractRSocket;
+import io.rsocket.Closeable;
+import io.rsocket.Payload;
+import io.rsocket.PayloadsMaxPerfSubscriber;
+import io.rsocket.PayloadsPerfSubscriber;
+import io.rsocket.RSocket;
 import io.rsocket.frame.decoder.PayloadDecoder;
 import io.rsocket.transport.local.LocalClientTransport;
 import io.rsocket.transport.local.LocalServerTransport;
@@ -59,9 +65,7 @@ public void awaitToBeConsumed() {
   @Setup
   public void setUp() throws NoSuchFieldException, IllegalAccessException {
     server =
-        RSocketFactory.receive()
-            .frameDecoder(PayloadDecoder.ZERO_COPY)
-            .acceptor(
+        RSocketServer.create(
                 (setup, sendingSocket) ->
                     Mono.just(
                         new AbstractRSocket() {
@@ -89,16 +93,14 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
                             return Flux.from(payloads);
                           }
                         }))
-            .transport(LocalServerTransport.create("server"))
-            .start()
+            .payloadDecoder(PayloadDecoder.ZERO_COPY)
+            .bind(LocalServerTransport.create("server"))
             .block();
 
     client =
-        RSocketFactory.connect()
-            .singleSubscriberRequester()
-            .frameDecoder(PayloadDecoder.ZERO_COPY)
-            .transport(LocalClientTransport.create("server"))
-            .start()
+        RSocketConnector.create()
+            .payloadDecoder(PayloadDecoder.ZERO_COPY)
+            .connect(LocalClientTransport.create("server"))
             .block();
 
     Field sendProcessorField = RSocketRequester.class.getDeclaredField("sendProcessor");

benchmarks/src/main/java/io/rsocket/StreamIdSupplierPerf.java renamed to benchmarks/src/main/java/io/rsocket/core/StreamIdSupplierPerf.java

@@ -1,8 +1,16 @@
-package io.rsocket;
+package io.rsocket.core;
 
 import io.netty.util.collection.IntObjectMap;
 import io.rsocket.internal.SynchronizedIntObjectHashMap;
-import org.openjdk.jmh.annotations.*;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.annotations.Warmup;
 import org.openjdk.jmh.infra.Blackhole;
 
 @BenchmarkMode(Mode.Throughput)