system.reactive — Реактивные расширения RxCpp в переполнении стека

У меня есть консольное приложение Win32, и я импортировал ссылки на Rx. Intellisense позволяет мне сделать это ….

using namespace System::Reactive;
using namespace System::Reactive::Concurrency;
using namespace System::Reactive::Disposables;
using namespace System::Reactive::Joins;
using namespace System::Reactive::Linq;
using namespace System::Reactive::PlatformServices;
using namespace System::Reactive::Subjects;
using namespace System::Reactive::Threading;
using namespace System::Reactive::Threading;
using namespace System::Data::Linq;
using namespace System::Xml::Linq;

Затем у меня есть несколько доступных классов, таких как ISubject / Subject и IObserver / Observer. Однако не существует IObservable. Я немного встревожен отсутствием документации для Rx с Cpp. Я пропускаю какие-либо очевидные ресурсы?

Я пробовал группы Channel9, Google, Stackoverflow и Facebook. Это рабочий код C #, который я сделал, я хотел бы, чтобы это работало с C ++. Эта функция объединяет все данные из разных источников наблюдения и выводит их в виде списка.

Таким образом, матрица 1 появляется из источника 1, матрица 2 появляется из источника 2. Они совпадают по id и выдвигаются вместе в виде списка.

public static IObservable<IList<TSource>> MergeById<TSource>(this IObservable<TSource> source, Func<IList<TSource>, TSource> mergeFunc, Func<TSource, int> keySelector, int bufferCount)
{
return Observable.Create<IList<TSource>>(o =>
{
var buffer = new Dictionary<int, IList<TSource>>();
return source.Subscribe<TSource>(i =>
{
var index = keySelector(i);
if (buffer.ContainsKey(index))
{
buffer[index].Add(i);
}
else
{
buffer.Add(index, new List<TSource>(){i});
}
if (buffer.Count==bufferCount)
{
o.OnNext(mergeFunc(buffer[index]));
buffer.Remove(index);
}
});
});
}

Любая помощь здесь будет хорошей. Не могу найти некоторые классы, которые я хочу, и другие аспекты синтаксиса отличаются. Есть ли источники или примеры, которые показывают, как все делается в C ++. Это, вероятно, может быть выведено из тех.

Вот оригинальный пост выпуска.

http://social.msdn.microsoft.com/Forums/en-US/58a25f70-a7b8-498b-ad7a-b57f3e1152da/rxcpp?forum=rx

Я пытался спросить здесь раньше, но ответа не было. Надеюсь, что это будет немного более плодотворно, теперь у меня есть больше информации о том, чего я пытаюсь достичь.

Спасибо.