Split reactivesocket-transport-netty into 2 projects. (#91)

* Split reactivesocket-transport-netty into 2 projects.

**Problem**
`reactivesocket-transport-netty` isn't an implementation of a transport but
two "tcp" and "websocket". Furthermore, Netty is an implementation details
rather than a transport.

**Solution**
Split `reactivesocket-transport-netty` into two transport libraries:

- `reactivesocket-transport-tcp`
- `reactivesocket-transport-websocket`

Introduce a common library `reactivesocket-netty` which only contains two
classes `MutableDirectByteBuf` and `NettyDuplexConnection` that are used in
both transport libraries.

**Note**
I didn't touch `ReactiveSocketServerHandler` which is discussed in a PR
on the old repo.

* Get rid of reactivesocket-netty

* Move the tests into the right module

* Get rid of any common classes

Author: stevegury

reactivesocket-transport-local/src/main/java/io/reactivesocket/local/LocalClientDuplexConnection.java

@@ -47,7 +47,6 @@ public Observable<Frame> getInput() {
 
     @Override
     public void addOutput(Publisher<Frame> o, Completable callback) {
-
         o
             .subscribe(new Subscriber<Frame>() {
 

reactivesocket-transport-netty/build.gradle renamed to reactivesocket-transport-tcp/build.gradle

@@ -1,4 +1,4 @@
-package io.reactivesocket.netty;
+package io.reactivesocket.transport.tcp;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.Channel;

reactivesocket-transport-netty/src/examples/java/io/reactivesocket/netty/EchoServer.java renamed to reactivesocket-transport-tcp/src/examples/java/io/reactivesocket/transport/tcp/EchoServer.java

@@ -1,4 +1,4 @@
-package io.reactivesocket.netty;
+package io.reactivesocket.transport.tcp;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
@@ -9,7 +9,7 @@
 import io.netty.handler.codec.http.HttpObjectAggregator;
 import io.netty.handler.codec.http.HttpServerCodec;
 import io.reactivesocket.RequestHandler;
-import io.reactivesocket.netty.tcp.server.ReactiveSocketServerHandler;
+import io.reactivesocket.transport.tcp.server.ReactiveSocketServerHandler;
 
 import java.util.List;
 

reactivesocket-transport-netty/src/examples/java/io/reactivesocket/netty/EchoServerHandler.java renamed to reactivesocket-transport-tcp/src/examples/java/io/reactivesocket/transport/tcp/EchoServerHandler.java

@@ -1,4 +1,4 @@
-package io.reactivesocket.netty;
+package io.reactivesocket.transport.tcp;
 
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandler;

reactivesocket-transport-netty/src/examples/java/io/reactivesocket/netty/HttpServerHandler.java renamed to reactivesocket-transport-tcp/src/examples/java/io/reactivesocket/transport/tcp/HttpServerHandler.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.reactivesocket.netty;
+package io.reactivesocket.transport.tcp;
 
 import io.netty.buffer.ByteBuf;
 import org.agrona.BitUtil;

reactivesocket-transport-netty/src/main/java/io/reactivesocket/netty/MutableDirectByteBuf.java renamed to reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/MutableDirectByteBuf.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.reactivesocket.netty.tcp.client;
+package io.reactivesocket.transport.tcp.client;
 
 import io.netty.bootstrap.Bootstrap;
 import io.netty.buffer.ByteBuf;

reactivesocket-transport-netty/src/main/java/io/reactivesocket/netty/tcp/client/ClientTcpDuplexConnection.java renamed to reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/client/ClientTcpDuplexConnection.java

@@ -13,14 +13,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.reactivesocket.netty.tcp.client;
+package io.reactivesocket.transport.tcp.client;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.reactivesocket.Frame;
-import io.reactivesocket.netty.MutableDirectByteBuf;
+import io.reactivesocket.transport.tcp.MutableDirectByteBuf;
 import io.reactivesocket.rx.Observer;
 
 import java.util.concurrent.CopyOnWriteArrayList;

reactivesocket-transport-netty/src/main/java/io/reactivesocket/netty/tcp/client/ReactiveSocketClientHandler.java renamed to reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/client/ReactiveSocketClientHandler.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.reactivesocket.netty.tcp.client;
+package io.reactivesocket.transport.tcp.client;
 
 import io.netty.channel.EventLoopGroup;
 import io.reactivesocket.*;
@@ -26,7 +26,7 @@
 import java.util.function.Consumer;
 
 /**
- * An implementation of {@link ReactiveSocketConnecot} that creates Netty TCP ReactiveSockets.
+ * An implementation of {@link ReactiveSocketConnector} that creates Netty TCP ReactiveSockets.
  */
 public class TcpReactiveSocketConnector implements ReactiveSocketConnector<SocketAddress> {
     private final ConnectionSetupPayload connectionSetupPayload;

reactivesocket-transport-netty/src/main/java/io/reactivesocket/netty/tcp/client/TcpReactiveSocketConnector.java renamed to reactivesocket-transport-tcp/src/main/java/io/reactivesocket/transport/tcp/client/TcpReactiveSocketConnector.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.reactivesocket.netty.tcp.server;
+package io.reactivesocket.transport.tcp.server;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandler;
@@ -27,7 +27,7 @@
 import io.reactivesocket.Frame;
 import io.reactivesocket.LeaseGovernor;
 import io.reactivesocket.ReactiveSocket;
-import io.reactivesocket.netty.MutableDirectByteBuf;
+import io.reactivesocket.transport.tcp.MutableDirectByteBuf;
 import org.agrona.BitUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;