Skip to content

Commit 8d3c9ad

Browse files
committed
Update to rxnetty 0.5.2-rc.5
#### Problem [rxnetty rc.5](https://github.com/ReactiveX/RxNetty/releases/tag/v0.5.2-rc.5) has a fix for backpressure which is required for channel/stream implementations. #### Modifications - Updated tcp transport to `io.reactivex:rxnetty-tcp:0.5.2-rc.5` - Minor formatting fix for `Frame.toString()` #### Result Latest and greatest dependencies.
1 parent 153ebea commit 8d3c9ad

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

reactivesocket-core/src/main/java/io/reactivesocket/Frame.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -567,7 +567,7 @@ public String toString() {
567567

568568
switch (type) {
569569
case LEASE:
570-
additionalFlags = " Permits: " + Lease.numberOfRequests(this) + ", TTL: " + Lease.ttl(this);
570+
additionalFlags = " Permits: " + Lease.numberOfRequests(this) + " TTL: " + Lease.ttl(this);
571571
break;
572572
case REQUEST_N:
573573
additionalFlags = " RequestN: " + RequestN.requestN(this);
@@ -584,10 +584,10 @@ public String toString() {
584584
break;
585585
case SETUP:
586586
additionalFlags = " Version: " + Setup.version(this)
587-
+ ", keep-alive interval: " + Setup.keepaliveInterval(this)
588-
+ ", max lifetime: " + Setup.maxLifetime(this)
589-
+ ", metadata mime type: " + Setup.metadataMimeType(this)
590-
+ ", data mime type: " + Setup.dataMimeType(this);
587+
+ " keep-alive interval: " + Setup.keepaliveInterval(this)
588+
+ " max lifetime: " + Setup.maxLifetime(this)
589+
+ " metadata mime type: " + Setup.metadataMimeType(this)
590+
+ " data mime type: " + Setup.dataMimeType(this);
591591
break;
592592
}
593593
} catch (Exception e) {

reactivesocket-transport-tcp/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
dependencies {
1818
compile project(':reactivesocket-core')
19-
compile 'io.reactivex:rxnetty-tcp:0.5.2-rc.4'
19+
compile 'io.reactivex:rxnetty-tcp:0.5.2-rc.5'
2020
compile 'io.reactivex:rxjava-reactive-streams:1.2.0'
2121

2222
testCompile project(':reactivesocket-test')

0 commit comments

Comments
 (0)