Update to latest reactivesocket

Author: rdegnan

build.gradle

@@ -14,13 +14,13 @@ subprojects {
     }
 
     dependencies {
-        compile 'io.reactivex:rxjava:1.1.2'
-        compile 'io.reactivex:rxjava-reactive-streams:1.0.1'
-        compile 'io.reactivesocket:reactivesocket:0.0.5'
-        compile 'org.hdrhistogram:HdrHistogram:2.1.7'
-        compile 'org.slf4j:slf4j-api:1.7.12'
+        compile 'io.reactivex:rxjava:latest.release'
+        compile 'io.reactivex:rxjava-reactive-streams:latest.release'
+        compile 'io.reactivesocket:reactivesocket:latest.release'
+        compile 'org.hdrhistogram:HdrHistogram:latest.release'
+        compile 'org.slf4j:slf4j-api:latest.release'
         testCompile 'junit:junit:4.12'
-        testCompile 'org.mockito:mockito-core:1.8.5'
+        testCompile 'org.mockito:mockito-core:1.10.19'
         testRuntime 'org.slf4j:slf4j-simple:1.7.12'
     }
 }

reactivesocket-aeron/src/main/java/io/reactivesocket/aeron/client/AeronReactiveSocketFactory.java

@@ -1,10 +1,24 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.aeron.client;
 
 import io.reactivesocket.ConnectionSetupPayload;
 import io.reactivesocket.DefaultReactiveSocket;
 import io.reactivesocket.ReactiveSocket;
 import io.reactivesocket.ReactiveSocketFactory;
-import io.reactivesocket.ReactiveSocketSocketAddressFactory;
 import io.reactivesocket.rx.Completable;
 import org.agrona.LangUtil;
 import org.reactivestreams.Publisher;
@@ -26,7 +40,7 @@
 /**
  * An implementation of {@link ReactiveSocketFactory} that creates Aeron ReactiveSockets.
  */
-public class AeronReactiveSocketFactory implements ReactiveSocketSocketAddressFactory<ReactiveSocket> {
+public class AeronReactiveSocketFactory implements ReactiveSocketFactory<SocketAddress, ReactiveSocket> {
     private static final Logger logger = LoggerFactory.getLogger(AeronReactiveSocketFactory.class);
 
     private final ConnectionSetupPayload connectionSetupPayload;

reactivesocket-aeron/src/test/java/io/reactivesocket/aeron/server/ServerAeronManagerTest.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.aeron.server;
 
 import io.aeron.driver.MediaDriver;

reactivesocket-jsr-356/src/main/java/io/reactivesocket/javax/websocket/client/WebSocketReactiveSocketFactory.java

@@ -19,7 +19,6 @@
 import io.reactivesocket.DefaultReactiveSocket;
 import io.reactivesocket.ReactiveSocket;
 import io.reactivesocket.ReactiveSocketFactory;
-import io.reactivesocket.ReactiveSocketSocketAddressFactory;
 import io.reactivesocket.javax.websocket.WebSocketDuplexConnection;
 import io.reactivesocket.rx.Completable;
 import org.glassfish.tyrus.client.ClientManager;
@@ -37,7 +36,7 @@
 /**
  * An implementation of {@link ReactiveSocketFactory} that creates JSR-356 WebSocket ReactiveSockets.
  */
-public class WebSocketReactiveSocketFactory implements ReactiveSocketSocketAddressFactory<ReactiveSocket> {
+public class WebSocketReactiveSocketFactory implements ReactiveSocketFactory<SocketAddress, ReactiveSocket> {
     private static final Logger logger = LoggerFactory.getLogger(WebSocketReactiveSocketFactory.class);
 
     private final ConnectionSetupPayload connectionSetupPayload;

reactivesocket-local/build.gradle

@@ -1,14 +0,0 @@
-group 'io.reactivesocket'
-version '0.1.3-SNAPSHOT'
-
-apply plugin: 'java'
-
-sourceCompatibility = 1.8
-
-repositories {
-    mavenCentral()
-}
-
-dependencies {
-    testCompile group: 'junit', name: 'junit', version: '4.11'
-}

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

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.local;
 
 import io.reactivesocket.DuplexConnection;

reactivesocket-local/src/main/java/io/reactivesocket/local/LocalClientReactiveSocketFactory.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.local;
 
 import io.reactivesocket.ConnectionSetupPayload;

reactivesocket-local/src/main/java/io/reactivesocket/local/LocalReactiveSocketManager.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.local;
 
 import java.util.concurrent.ConcurrentHashMap;

reactivesocket-local/src/main/java/io/reactivesocket/local/LocalServerDuplexConection.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.local;
 
 import io.reactivesocket.DuplexConnection;

reactivesocket-local/src/main/java/io/reactivesocket/local/LocalServerReactiveSocketFactory.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2016 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.reactivesocket.local;
 
 import io.reactivesocket.ConnectionSetupHandler;