Reactive extension for Delphi

Reactive programming on Delphi

Strongly recommend to read the book

Introduction

Documentation consists of next parts:

• Tutorials
• How-to guides
• Technical references

Important to understand.

Reactive approach implementation for Delphi involves problem of reference counting for class instances. RxDelphi partially solves this problem by implementing TSmartVariable record that incapsulate automatic references counting and garbage collection, so developer can pass class instances to data streams, probably sheduled in separate threads.

But, auto references counting mechanism don't solve problem of simultenious access from separete threads. You have to solve this problem by Locks/Mutexes or, probably, by implementing immutable data structures (the simplest way to do it - simple copying).

TODO

• GroupBy
• SubscribeOn