public class UnconsumedReads
extends java.lang.Object
Constructor and Description |
---|
UnconsumedReads() |
Modifier and Type | Method and Description |
---|---|
static void |
ensureAllReadsConsumed(Pipeline pipeline) |
public static void ensureAllReadsConsumed(Pipeline pipeline)