fix request channel not found exception with named socket and fixed name socket wrapper to send data

Author: robertroeser

proteus-client/src/main/java/io/netifi/proteus/rsocket/NamedRSocketClientWrapper.java

@@ -4,7 +4,6 @@
 import io.netty.buffer.ByteBufAllocator;
 import io.rsocket.Payload;
 import io.rsocket.RSocket;
-import io.rsocket.rpc.RSocketRpcService;
 import io.rsocket.rpc.frames.Metadata;
 import io.rsocket.util.ByteBufPayload;
 import io.rsocket.util.RSocketProxy;
@@ -22,7 +21,7 @@ private NamedRSocketClientWrapper(String name, RSocket source) {
   }
 
   /**
-   * Wraps an RSocket with {@link RSocketProxy} and {@link RSocketRpcService}
+   * Wraps an RSocket with {@link RSocketProxy} and RSocketRpcService
    *
    * @param name what you want your RSocket to be found as
    * @param source the raw socket to handle to wrap
@@ -63,6 +62,6 @@ private Payload wrap(Payload payload) {
     ByteBuf metadata =
         Metadata.encode(ByteBufAllocator.DEFAULT, name, name, payload.sliceMetadata());
 
-    return ByteBufPayload.create(payload.sliceMetadata().retain(), metadata);
+    return ByteBufPayload.create(payload.sliceData().retain(), metadata);
   }
 }

proteus-client/src/main/java/io/netifi/proteus/rsocket/NamedRSocketServiceWrapper.java

@@ -48,8 +48,7 @@ public String getService() {
   }
 
   @Override
-  public final Flux<Payload> requestChannel(Payload payload, Flux<Payload> publisher) {
-    return reactor.core.publisher.Flux.error(
-        new UnsupportedOperationException("Request-Channel not implemented."));
+  public Flux<Payload> requestChannel(Payload payload, Flux<Payload> publisher) {
+    return super.requestChannel(publisher);
   }
 }