ParallelQuery Batching

Question

How can I collect a ParallelQuery<T> into batches of size n in parallel? Something like the MoreLinq Batch function, but for ParallelQuery:

ParallelQuery<T[]> Batch(ParallelQuery<T> values, int batchSize)

Ideally, it would be lazy and streaming like other ParallelQuery methods.