File tree Expand file tree Collapse file tree 2 files changed +0
-2
lines changed
src/main/java/io/reactivesocket Expand file tree Collapse file tree 2 files changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -130,7 +130,6 @@ private void decode() {
130
130
byte [] copy = new byte [b .limit ()];
131
131
b .get (copy );
132
132
String data = new String (copy );
133
- System .out .println ("RAW: " + data );
134
133
int separator = data .indexOf ('|' );
135
134
String prefix = data .substring (0 , separator );
136
135
this .type = MessageType .values [Integer .parseInt (prefix .substring (1 , data .indexOf (']' )))];
Original file line number Diff line number Diff line change @@ -49,7 +49,6 @@ public Publisher<Void> acceptConnection(DuplexConnection ws) {
49
49
final ConcurrentHashMap <Integer , CancellationToken > cancellationObservables = new ConcurrentHashMap <>();
50
50
51
51
return toPublisher (toObservable (ws .getInput ()).flatMap (message -> {
52
- System .out .println ("message: " + message );
53
52
if (message .getMessageType () == MessageType .SUBSCRIBE_REQUEST_RESPONSE ) {
54
53
CancellationToken cancellationToken = CancellationToken .create ();
55
54
cancellationObservables .put (message .getMessageId (), cancellationToken );
You can’t perform that action at this time.
0 commit comments