// RxWindows.h
|
#pragma once
|
#include <functional>
|
#include "IRxObject.h"
|
#include "IObserver.h"
|
#include "IAny.h"
|
#include "IThrowable.h"
|
#include "IObservable.h"
|
#include "IObservableEmitter.h"
|
|
typedef std::function<void(IAny *pAny)> ONNEXT;
|
typedef std::function<void()> ONCOMPLETE;
|
typedef std::function<void(IThrowable *pThrowable)> ONERROR;
|
typedef std::function<void(IObservableEmitter *e)> SUBSCRIBE;
|
|
class IRxWindows
|
{
|
public:
|
virtual IObserver *allocObserver(ONNEXT pfOnNext, ONCOMPLETE pfOnComplete, ONERROR pfOnError) = 0;
|
virtual void freeObserver(IObserver *pObserver) = 0;
|
virtual unsigned long getMainThreadId() = 0;
|
virtual unsigned long mainThread() = 0;
|
virtual unsigned long newThread() = 0;
|
virtual int termThread(unsigned long nThread) = 0;
|
virtual void enableLog(int level) = 0;
|
};
|
|
|
extern "C" _declspec(dllexport) int RX_Init();
|
extern "C" _declspec(dllexport) int RX_Term();
|
extern "C" _declspec(dllexport) IRxWindows *RX_GetRxWindows();
|
extern "C" _declspec(dllexport) IObservable *RX_AllocaObservable(SUBSCRIBE pfSubscribe);
|
extern "C" _declspec(dllexport) void RX_FreeObservable(IObservable *pObservable);
|
extern "C" _declspec(dllexport) IAny *RX_AllocaAny();
|
