Upgrade to RxJava 1.1.5

After the fix for ReactiveX/RxNetty#509 we can remove the workaround
to concatenate with an empty Observable for the request body and
upgrade to the latest RxJava 1.1.5.

Issues: #103
This commit is contained in:
Rossen Stoyanchev
2016-06-01 17:32:05 -04:00
parent 8cf5ea91f8
commit 431fedccc7
2 changed files with 2 additions and 4 deletions

View File

@@ -93,9 +93,7 @@ public class RxNettyServerHttpRequest extends AbstractServerHttpRequest {
@Override
public Flux<DataBuffer> getBody() {
Observable<DataBuffer> content =
this.request.getContent().map(dataBufferFactory::wrap);
content = content.concatWith(Observable.empty()); // See GH issue #58
Observable<DataBuffer> content = this.request.getContent().map(dataBufferFactory::wrap);
return RxJava1ObservableConverter.from(content);
}