Strongly recommend to read the book
Documentation consists of next parts:
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).
- GroupBy
- SubscribeOn