Skip to content

Commit c7c7422

Browse files
committed
Fix unused imports violation
1 parent 8bd9464 commit c7c7422

File tree

1 file changed

+8
-9
lines changed

1 file changed

+8
-9
lines changed

spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2017-2019 the original author or authors.
2+
* Copyright 2017-2020 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -27,7 +27,6 @@
2727

2828
import reactor.core.publisher.EmitterProcessor;
2929
import reactor.core.publisher.Flux;
30-
import reactor.core.publisher.FluxSink;
3130
import reactor.core.scheduler.Schedulers;
3231

3332
/**
@@ -87,13 +86,13 @@ private static final class PollableChannelPublisherAdapter<T> implements Publish
8786
public void subscribe(Subscriber<? super Message<T>> subscriber) {
8887
Flux
8988
.<Message<T>>create(sink ->
90-
sink.onRequest(n -> {
91-
Message<?> m;
92-
while (!sink.isCancelled() && n-- > 0
93-
&& (m = this.channel.receive()) != null) { // NOSONAR
94-
sink.next((Message<T>) m);
95-
}
96-
}))
89+
sink.onRequest(n -> {
90+
Message<?> m;
91+
while (!sink.isCancelled() && n-- > 0
92+
&& (m = this.channel.receive()) != null) { // NOSONAR
93+
sink.next((Message<T>) m);
94+
}
95+
}))
9796
.subscribeOn(Schedulers.elastic())
9897
.subscribe(subscriber);
9998
}

0 commit comments

Comments
 (0)