Skip to content

Instantly share code, notes, and snippets.

@Stat1cV01D
Stat1cV01D / rx-backpressure_buffer.hpp
Last active March 19, 2020 17:21
Draft implementation of Backpressure operator for RxCpp
// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
// Modifications by stat1c_v01d
#pragma once
/*! \file rx-backpressure_buffer.hpp
\brief Return an observable that emits buffers every period time interval and collects items from this observable for period of time into each produced buffer.
If the skip parameter is set, Return an observable that emits buffers every skip time interval and collects items from this observable for period of time into each produced buffer, on the specified scheduler.