High throughput, concurrent, threadsafe functional reactive event processing library