Remove unnecessary deprecation suppression

This commit is contained in:
Juergen Hoeller 2017-11-29 15:44:08 +01:00
parent b55a2631ba
commit 873cb4e58b
2 changed files with 2 additions and 7 deletions

View File

@ -60,13 +60,11 @@ class Netty4ClientHttpResponse extends AbstractClientHttpResponse {
@Override @Override
@SuppressWarnings("deprecation")
public int getRawStatusCode() throws IOException { public int getRawStatusCode() throws IOException {
return this.nettyResponse.getStatus().code(); return this.nettyResponse.getStatus().code();
} }
@Override @Override
@SuppressWarnings("deprecation")
public String getStatusText() throws IOException { public String getStatusText() throws IOException {
return this.nettyResponse.getStatus().reasonPhrase(); return this.nettyResponse.getStatus().reasonPhrase();
} }

View File

@ -50,9 +50,7 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
private final Flux<T> source; private final Flux<T> source;
public ChannelSendOperator(Publisher<? extends T> source, Function<Publisher<T>, public ChannelSendOperator(Publisher<? extends T> source, Function<Publisher<T>, Publisher<Void>> writeFunction) {
Publisher<Void>> writeFunction) {
this.source = Flux.from(source); this.source = Flux.from(source);
this.writeFunction = writeFunction; this.writeFunction = writeFunction;
} }
@ -92,8 +90,7 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
* <p>Also uses {@link WriteCompletionBarrier} to communicate completion * <p>Also uses {@link WriteCompletionBarrier} to communicate completion
* and detect cancel signals from the completion subscriber. * and detect cancel signals from the completion subscriber.
*/ */
@SuppressWarnings("deprecation") private class WriteBarrier implements CoreSubscriber<T>, Subscription, Publisher<T> {
private final class WriteBarrier implements CoreSubscriber<T>, Subscription, Publisher<T> {
/* Bridges signals to and from the completionSubscriber */ /* Bridges signals to and from the completionSubscriber */
private final WriteCompletionBarrier writeCompletionBarrier; private final WriteCompletionBarrier writeCompletionBarrier;