Skip to content

Commit b5cd8fd

Browse files
committed
fix comment
1 parent 7e0b275 commit b5cd8fd

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

core/src/main/java/io/netty/loom/MpscUnboundedStream.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ private int newBufferAndOffset(E[] nextBuffer, final long index) {
325325
public final boolean isEmpty() {
326326
// Order matters!
327327
// Loading consumer before producer allows for producer increments after consumer index is read.
328-
// This ensures this method is conservative in it's estimate. Note that as this is an MPMC there is
328+
// This ensures this method is conservative in it's estimate. Note that as this is an MPSC q there is
329329
// nothing we can do to make this an exact method.
330330
return (this.lvConsumerIndex() == (this.lvProducerIndex() & CLOSED_MASK));
331331
}

0 commit comments

Comments
 (0)