presto-main/src/main/java/io/prestosql/operator/PartitionedConsumption.java/PartitionedConsumption/load
class PartitionedConsumption:        public ListenableFuture<T> load()
        {
            requested.set(null);
            return loaded;
        }