Rename modules and provide a simple implementation of Reactive Streams with Netty 4.

Author: jbrisbin

build.gradle

@@ -74,46 +74,46 @@ subprojects { subproject ->
 	}
 }
 
-project('reactive-ipc-core') {
+project('ripc-core') {
 	description = 'Reactive IPC Core Components'
 	dependencies {
 		// Reactive Streams
 		compile "org.reactivestreams:reactive-streams:$reactiveStreamsVersion"
 	}
 }
 
-project('reactive-ipc-tcp') {
+project('ripc-protocol-tcp') {
 	description = 'Reactive IPC TCP Components'
 	dependencies {
 		// ripc-core
-		compile project(":reactive-ipc-core")
+		compile project(":ripc-core")
 	}
 }
 
-project('reactive-ipc-netty4') {
+project('ripc-transport-netty4') {
 	description = 'Reactive IPC Netty 4.x Transport Implementation'
 	dependencies {
 		// ripc-tcp
-		compile project(":reactive-ipc-tcp")
+		compile project(":ripc-protocol-tcp")
 
 		// Netty
 		compile "io.netty:netty-all:$nettyVersion"
 	}
 }
 
-project('reactive-ipc-rxjava1') {
+project('ripc-composition-rxjava1') {
 	description = 'Reactive IPC Composition Layer Implementation'
 	dependencies {
 		// ripc-tcp
-		compile project(":reactive-ipc-netty4")
+		compile project(":ripc-transport-netty4")
 
 		// RxJava 1.0
 		compile "io.reactivex:rxjava:$rxjava1Version"
 	}
 }
 
 configure(rootProject) {
-	description = "Reactive Streams IPC"
+	description = "Reactive IPC"
 
 	task api(type: Javadoc) {
 		group = "Documentation"

reactive-ipc-rxjava1/src/main/java/io/ripc/composition/rx/package-info.java renamed to ripc-composition-rxjava1/src/main/java/io/ripc/composition/rx/package-info.java

@@ -0,0 +1,26 @@
+package io.ripc.core;
+
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * Created by jbrisbin on 3/10/15.
+ */
+public class NamedDaemonThreadFactory implements ThreadFactory {
+
+	private final AtomicLong counter = new AtomicLong(1);
+	private final String prefix;
+
+	public NamedDaemonThreadFactory(String prefix) {
+		this.prefix = prefix;
+	}
+
+	@Override
+	public Thread newThread(Runnable r) {
+		String name = prefix + "-" + counter.getAndIncrement();
+		Thread t = new Thread(r, name);
+		t.setDaemon(true);
+		return t;
+	}
+	
+}

reactive-ipc-core/src/main/java/io/ripc/core/package-info.java renamed to ripc-composition-rxjava1/src/test/java/io/ripc/composition/rx/package-info.java

@@ -0,0 +1,21 @@
+package io.ripc.core;
+
+import org.reactivestreams.Subscriber;
+
+/**
+ * Created by jbrisbin on 3/10/15.
+ */
+public abstract class Specification {
+
+	protected Specification() {
+	}
+
+	public static <T> boolean spec_3_9_verifyPositiveDemand(long demand, Subscriber<T> subscriber) {
+		if (demand > 0) {
+			return true;
+		}
+		subscriber.onError(new IllegalArgumentException("Spec 3.9: Request signals must be a positive number."));
+		return false;
+	}
+
+}

ripc-core/src/main/java/io/ripc/core/NamedDaemonThreadFactory.java

@@ -0,0 +1,129 @@
+package io.ripc.core.io;
+
+import java.nio.ByteBuffer;
+import java.nio.charset.CharsetDecoder;
+import java.util.List;
+
+/**
+ * Common abstraction to provide additional functionality beyond a traditional {@link java.nio.ByteBuffer} while not
+ * restricting the dedicated functionality provided by concrete implementations from various transport libraries that
+ * might offer features like zero-copy.
+ * <p>
+ * A {@code Buffer} can be anything. It is not limited to byte buffers. A {@code Buffer} could represent realized
+ * objects descended from raw data.
+ * </p>
+ */
+public interface Buffer<B> extends Cloneable,
+                                   AutoCloseable,
+                                   Comparable<Buffer<B>>,
+                                   Iterable<Buffer<B>> {
+
+	int position();
+
+	Buffer<B> position(int pos);
+
+	int limit();
+
+	Buffer<B> limit(int limit);
+
+	int capacity();
+
+	Buffer<B> capacity(int capacity);
+
+	int remaining();
+
+	Buffer<B> skip(int len);
+
+	Buffer<B> clear();
+
+	Buffer<B> compact();
+
+	Buffer<B> flip();
+
+	Buffer<B> rewind();
+
+	Buffer<B> rewind(int len);
+
+	Buffer<B> clone();
+
+	Buffer<B> copy();
+
+	Buffer<B> slice(int start, int len);
+
+	Iterable<Buffer<B>> split(byte delimiter);
+
+	Iterable<Buffer<B>> split(byte delimiter, boolean stripDelimiter);
+
+	Iterable<Buffer<B>> split(byte delimiter, boolean stripDelimiter, List<Buffer<B>> preallocatedList);
+
+	Iterable<Buffer<B>> split(Buffer<B> delimiter);
+
+	Iterable<Buffer<B>> split(Buffer<B> delimiter, boolean stripDelimiter);
+
+	Iterable<Buffer<B>> split(Buffer<B> delimiter, boolean stripDelimiter, List<Buffer<B>> preallocatedList);
+
+	Buffer<B> prepend(B data);
+
+	Buffer<B> prepend(Buffer<B> buffer);
+
+	Buffer<B> prepend(ByteBuffer buffer);
+
+	Buffer<B> prepend(CharSequence chars);
+
+	Buffer<B> prepend(byte[] bytes);
+
+	Buffer<B> prepend(byte b);
+
+	Buffer<B> prepend(char c);
+
+	Buffer<B> prepend(short s);
+
+	Buffer<B> prepend(int i);
+
+	Buffer<B> prepend(long l);
+
+	Buffer<B> append(B data);
+
+	Buffer<B> append(Buffer<B> buffer);
+
+	Buffer<B> append(ByteBuffer buffer);
+
+	Buffer<B> append(CharSequence chars);
+
+	Buffer<B> append(byte[] bytes);
+
+	Buffer<B> append(byte b);
+
+	Buffer<B> append(char c);
+
+	Buffer<B> append(short s);
+
+	Buffer<B> append(int i);
+
+	Buffer<B> append(long l);
+
+	byte readByte();
+
+	void readBytes(byte[] bytes);
+
+	short readShort();
+
+	int readInt();
+
+	float readFloat();
+
+	double readDouble();
+
+	long readLong();
+
+	char readChar();
+
+	void readChars(char[] chars);
+
+	String readString();
+
+	String readString(CharsetDecoder decoder);
+
+	B get();
+
+}

ripc-core/src/main/java/io/ripc/core/Specification.java

@@ -10,7 +10,7 @@
 
 	<logger name="io.ripc" level="debug"/>
 
-	<root level="info">
+	<root level="debug">
 		<appender-ref ref="stdout"/>
 	</root>
 

ripc-core/src/main/java/io/ripc/core/io/Buffer.java

@@ -0,0 +1,13 @@
+package io.ripc.protocol.tcp;
+
+import io.ripc.core.io.Buffer;
+import org.reactivestreams.Publisher;
+
+/**
+ * Created by jbrisbin on 3/10/15.
+ */
+public interface Connection<B> extends Publisher<Buffer<B>> {
+
+	void write(Publisher<Buffer<B>> data);
+
+}

reactive-ipc-core/src/test/java/io/ripc/core/package-info.java renamed to ripc-core/src/main/java/io/ripc/core/package-info.java

@@ -0,0 +1,9 @@
+package io.ripc.protocol.tcp;
+
+import org.reactivestreams.Publisher;
+
+/**
+ * Created by jbrisbin on 3/10/15.
+ */
+public interface ConnectionPublisher<B> extends Publisher<Connection<B>> {
+}