Allow streaming of facts into a session

[doug-martin]

See https://groups.google.com/d/msg/nools/tkbmSt4snqI/hEsCY5qRvKIJ for a description.

[bthibault]

Doug, where should I look in the code for this? I want to start contributing to the project

[doug-martin]

I would start by looking at the executionStrategy and looking how the engines execution loop currently works. Then see if there is a way to adapt that to a streaming model.

[bthibault]

great thanks I'll start diving here and there and see if I can start getting familiar w/ the code base.

[bthibault]

I'm still looking at this as i have large numbers of facts to run against.

I'm looking at implementing the http://reactive-extensions.github.io/RxJS/ library.

I think we can do something like this :

sourceStream -> backpressure mechanism -> async stream of promises(A+spec) -> outStream

I need to research a little more on how to control the back pressure though , but the executionStrategy seems pretty straight forward

[bthibault]

hmmm.. i just found matchUntilHalt 'reactive mode' ... this essentially can take a stream and respond via a stream fact by fact. A little nicer streaming abstraction would be a nice to have, but 'streaming support' essentially already works.