ReactiveX

RxCpp

C++2014–2018

ReactiveX / RxCpp

RxCpp

Reactive Extensions for C++

Systems & Infrastructure Libraries & SDKs

Explore on GitHub Read Hacker News discussions

5Distinct people

5Mentions

0Explicit recommenders

3.2KGitHub stars

REPOSITORY AT A GLANCE

What to know before exploring

What it is

Reactive Extensions for C++

GitHub

Where it is used

No documented product use has been verified yet.

What people are saying

No recommendation phrase was found in the indexed comments.

No classified warning is attached to this page. Read the discussions before treating silence as approval.

Also in these discussions

No other repository is repeatedly linked in the same discussions.

This week on Hacker News

Nov 7–Nov 14 UTC · Direct repository links and separately labeled related project stories. Indexed through 11/14/2026, 11:56:56 AM UTC.

No direct repository links were found in the indexed HN discussions over the past seven days. Older discussions are available below.

Mentions over time

HN mentions by year5 dated mentions

Observed mentions: 2014-06-23 07:40:31 UTC to 2018-12-29 03:03:08 UTC.

Counts come from the repository’s dated source evidence. Index cutoff: 2026-11-02 08:16:59 UTC.

View mention counts and date ranges

UTC ranges include their start and exclude their end. Select a period to filter the source evidence.
Period	Start (UTC)	End (exclusive, UTC)	Mentions	Comments
2014	2014-01-01 00:00:00 UTC	2015-01-01 00:00:00 UTC	2	2
2015	2015-01-01 00:00:00 UTC	2016-01-01 00:00:00 UTC	1	1
2016	2016-01-01 00:00:00 UTC	2017-01-01 00:00:00 UTC	0	0
2017	2017-01-01 00:00:00 UTC	2018-01-01 00:00:00 UTC	1	1
2018	2018-01-01 00:00:00 UTC	2019-01-01 00:00:00 UTC	1	1

What Hacker News says

5 sources

shawxe·Dec 29, 2018

The pipe is an operator overload. That said, while I wouldn't exactly call it idiomatic, it's not entirely unheard of in third party libraries. RxCpp (https://github.com/ReactiveX/RxCpp), the C++ ReactiveX library, makes use of a similarly overloaded pipe operator, for example. Personally, I think I'd be more apt to use the "functional" style.

In Show HN: LazyCode – C++14 composable, lazily evaluated map, filter, fold

utopcell·Feb 7, 2017

Microsoft has open-sourced their LINQ C++ implementation [1] which allows you to do things like this (from their repo) : random_device rd; // non-deterministic generator mt19937 gen(rd()); uniform_int_distribution<> dist(4, 18); // for testing purposes, produce byte stream that from lines of text auto bytes = range(0, 10) | flat_map([&](int i){ auto body = from((uint8_t)('A' + i)) | repeat(dist(gen)) | as_dynamic(); auto delim = from((uint8_t)'\r'); return from(body, delim) | concat(); }) | window(17) | flat_map([](observable<uint8_t> w){ return w | reduce( vector<uint8_t>(), [](vector<uint8_t> v, uint8_t b){ v.push_back(b);

Read the rest

return v; }) | as_dynamic(); }) | tap([](vector<uint8_t>& v){ // print input packet of bytes copy(v.begin(), v.end(), ostream_iterator<long>(cout, " ")); cout << endl; }); // // recover lines of text from byte stream // auto removespaces = [](string s){ s.erase(remove_if(s.begin(), s.end(), ::isspace), s.end()); return s; }; // create strings split on \r auto strings = bytes | concat_map([](vector<uint8_t> v){ string s(v.begin(), v.end()); regex delim(R"/(\r)/"); cregex_token_iterator cursor(&s[0], &s[0] + s.size(), delim, {-1, 0}); cregex_token_iterator end; vector<string> splits(cursor, end); return iterate(move(splits)); }) | filter([](const string& s){ return !s.empty(); }) | publish() | ref_count(); // filter to last string in each line auto closes = strings | filter( [](const string& s){ return s.back() == '\r'; }) | Rx::map([](const string&){return 0;}); // group strings by line auto linewindows = strings | window_toggle(closes | start_with(0), [=](int){return closes;}); // reduce the strings for a line into one string auto lines = linewindows | flat_map([&](observable<string> w) { return w | start_with<string>("") | sum() | Rx::map(removespaces); }); // print result lines | subscribe<string>(println(cout)); [1] https://github.com/Reactive-Extensions/RxCpp

In In Defense of C++

learc83·Jun 19, 2015

Has anyone used the Reactive Extensions for C++? I've used RxJs fairly extensively, but I haven't tried it any other languages. Rx solves a similar problem, but observables are more general than promises. https://github.com/Reactive-Extensions/RxCpp

In Futures for C++11 at Facebook

profquail·Aug 3, 2014

There's also Rx.cpp[1], which follows in the same vein as Rx.NET, RxJava, and RxJS (so may be easier to pick up if you're familiar with one of those). [1] https://github.com/Reactive-Extensions/RxCpp

In C++React: A reactive programming library for C++11

mattpodwysocki·Jun 23, 2014

Seems very close in implementation to RxCPP for push based streams and IxCPP for pull based, which has been created by Microsoft and now controlled by Microsoft Open Technologies. This library though does not require C++14 and is being actively developed: https://github.com/Reactive-Extensions/RxCPP

In Streams – Lazy evaluation in C++14