Method SlidingWindow

mlx/data/stream/SlidingWindow.cpp:10–29

namespace data {
namespace stream {
SlidingWindow::SlidingWindow(
    const std::shared_ptr<Stream>& stream,
    const std::string& key,
    int64_t size,
    int64_t stride,
    int dim,
    const std::string& index_key)
    : stream_(stream),
      key_(key),
      size_(size),
      stride_(stride),
      dim_(dim),
      index_key_(index_key) {
  if (size <= 0) {
    throw std::runtime_error("SlidingWindow: size must be strictly positive");
  }
  if (stride <= 0) {
    throw std::runtime_error("SlidingWindow: stride must be strictly positive");
  }
}

Sample SlidingWindow::next() const {
  std::unique_lock lock(mutex_);