changes examples location to fit the their purpose

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

Author: OlegDokuka

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/duplex/TaskProcessingWithServerSideNotificationsExample.java renamed to rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/fnf/TaskProcessingWithServerSideNotificationsExample.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.rsocket.examples.transport.tcp.duplex;
+package io.rsocket.examples.transport.tcp.fnf;
 
 import io.rsocket.ConnectionSetupPayload;
 import io.rsocket.Payload;

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/lease/LeaseExample.java

@@ -20,7 +20,6 @@
 import io.rsocket.RSocket;
 import io.rsocket.core.RSocketConnector;
 import io.rsocket.core.RSocketServer;
-import io.rsocket.examples.transport.tcp.stream.StreamingClient;
 import io.rsocket.lease.Lease;
 import io.rsocket.lease.LeaseStats;
 import io.rsocket.lease.Leases;
@@ -45,7 +44,7 @@
 
 public class LeaseExample {
 
-  private static final Logger logger = LoggerFactory.getLogger(StreamingClient.class);
+  private static final Logger logger = LoggerFactory.getLogger(LeaseExample.class);
 
   private static final String SERVER_TAG = "server";
   private static final String CLIENT_TAG = "client";

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/stream/StreamingClient.java renamed to rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/stream/ClientStreamingToServer.java

@@ -29,9 +29,9 @@
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Flux;
 
-public final class StreamingClient {
+public final class ClientStreamingToServer {
 
-  private static final Logger logger = LoggerFactory.getLogger(StreamingClient.class);
+  private static final Logger logger = LoggerFactory.getLogger(ClientStreamingToServer.class);
 
   public static void main(String[] args) {
     RSocketServer.create(

rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/duplex/DuplexClient.java renamed to rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/stream/ServerStreamingToClient.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.rsocket.examples.transport.tcp.duplex;
+package io.rsocket.examples.transport.tcp.stream;
 
 import static io.rsocket.SocketAcceptor.forRequestStream;
 
@@ -29,7 +29,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
-public final class DuplexClient {
+public final class ServerStreamingToClient {
 
   public static void main(String[] args) {