search

kmgreen2 / agglo

Agglo: A Process-Anywhere Framework for Event Stream Processing
https://kmgreen2.github.io/agglo/
MIT License
2 stars 0 forks source link

Create NewSubstreamStore Constructor #12

Closed kmgreen2 closed 3 years ago

kmgreen2 commented 3 years ago

The constructor should should return an object that wraps StreamStore and does operations on a given substream.

This will be used by StreamStoreTee() that will process in-bound messages that have an objectStore reference.

kmgreen2 commented 3 years ago

Done