Skip to content

Commit

Permalink
fix reactor#1035 Make MPSC queue implementation package private
Browse files Browse the repository at this point in the history
The `MpscLinkedQueue` was another class that shouldn't have been
released as public. It is now package private, since all access have
been converted to the new Queues.unboundedMultiproducer() method.
  • Loading branch information
simonbasle committed Jan 29, 2018
1 parent 236cb97 commit 0d59d84
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -274,7 +274,7 @@ project('reactor-core') {
//TODO after a release, bump the gradle.properties baseline
//TODO after a release, remove the reactor-core exclusions below if any
//gh-1036
classExcludes = ['reactor.core.publisher.FluxIndex', 'reactor.core.publisher.FluxIndexFuseable', 'reactor.core.publisher.FluxDelaySequence']
classExcludes = ['reactor.core.publisher.FluxIndex', 'reactor.core.publisher.FluxIndexFuseable', 'reactor.core.publisher.FluxDelaySequence', 'reactor.util.concurrent.MpscLinkedQueue']
}

javadoc {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
* A multi-producer single consumer unbounded queue.
* @param <E> the contained value type
*/
public class MpscLinkedQueue<E> extends AbstractQueue<E> implements BiPredicate<E, E> {
final class MpscLinkedQueue<E> extends AbstractQueue<E> implements BiPredicate<E, E> {
private volatile LinkedQueueNode<E> producerNode;

private final static AtomicReferenceFieldUpdater<MpscLinkedQueue, LinkedQueueNode> PRODUCER_NODE_UPDATER
Expand Down

0 comments on commit 0d59d84

Please sign in to comment.