Github user smashew commented on the pull request:
https://github.com/apache/incubator-streams/pull/15#issuecomment-43804858
In the runtime environments, save LocalStreamsBuilder everything should be
run as a thread in a thread monitor, which can then be checked to see if there
is an active queue. Then we should document that the 'writeDatum' method is
already threaded and the user shouldn't thread the call further. Or at least
know that it is tracking the method 'writeDatum' to establish that it's effort
is completed. (see my fork for a reference implementation of exactly this)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
