Method prepareStreamForDeserialize

bolt/exec/ExchangeQueue.cpp:62–64

}

std::unique_ptr<ByteInputStream> SerializedPage::prepareStreamForDeserialize() {
  return std::make_unique<ByteInputStream>(std::move(ranges_));
}

void ExchangeQueue::noMoreSources() {
  std::vector<ContinuePromise> promises;