From dd1989dd6ad20a3c56b6ea812926ed0528584e75 Mon Sep 17 00:00:00 2001
From: Ben Christensen <benjchristensen@netflix.com>
Date: Tue, 21 Jul 2015 21:41:17 -0700
Subject: [PATCH] Remove Stray Printlns

---
 src/main/java/io/reactivesocket/Message.java                     | 1 -
 .../java/io/reactivesocket/ReactiveSocketServerProtocol.java     | 1 -
 2 files changed, 2 deletions(-)

diff --git a/src/main/java/io/reactivesocket/Message.java b/src/main/java/io/reactivesocket/Message.java
index 2ed9bd097..24ce2fcdb 100644
--- a/src/main/java/io/reactivesocket/Message.java
+++ b/src/main/java/io/reactivesocket/Message.java
@@ -130,7 +130,6 @@ private void decode() {
 		byte[] copy = new byte[b.limit()];
 		b.get(copy);
 		String data = new String(copy);
-		System.out.println("RAW: " + data);
 		int separator = data.indexOf('|');
 		String prefix = data.substring(0, separator);
 		this.type = MessageType.values[Integer.parseInt(prefix.substring(1, data.indexOf(']')))];
diff --git a/src/main/java/io/reactivesocket/ReactiveSocketServerProtocol.java b/src/main/java/io/reactivesocket/ReactiveSocketServerProtocol.java
index f57882e0d..3a5ae8374 100644
--- a/src/main/java/io/reactivesocket/ReactiveSocketServerProtocol.java
+++ b/src/main/java/io/reactivesocket/ReactiveSocketServerProtocol.java
@@ -49,7 +49,6 @@ public Publisher<Void> acceptConnection(DuplexConnection ws) {
 		final ConcurrentHashMap<Integer, CancellationToken> cancellationObservables = new ConcurrentHashMap<>();
 
 		return toPublisher(toObservable(ws.getInput()).flatMap(message -> {
-			System.out.println("message: " + message);
 			if (message.getMessageType() == MessageType.SUBSCRIBE_REQUEST_RESPONSE) {
 				CancellationToken cancellationToken = CancellationToken.create();
 				cancellationObservables.put(message.getMessageId(), cancellationToken);