Summary

In this chapter, we simulated a real-world application with our stock market program. We wrote it in a somewhat traditional way using thread pools and a custom queue implementation. We then refactored it into a CES style using RxClojure's observable sequences.

The resulting program is shorter, simpler, and easier to read once you get familiar with the core concepts of RxClojure and RxJava.

In the next chapter, we will be introduced to core.async, in preparation for implementing our own basic CES framework.