Processing a flux pipeline results in empty data when doing this e.g. with the metafacture-playground, while it works fine when processing it using standalone metafacture-core.
The cause is probably: if the JVM is stopped after processing the streams of the receivers are closed automatically, thus the data is output correctly, while an unstopped JVM (like with metafacture-playground) doesn't close all streams properly (in some cases). Here it is the LineRecorder which doesn't close its receiver.
This came up in https://github.com/metafacture/metafacture-playground/issues/25#issuecomment-995795261:
Processing a flux pipeline results in empty data when doing this e.g. with the metafacture-playground, while it works fine when processing it using standalone
metafacture-core. The cause is probably: if the JVM is stopped after processing the streams of the receivers are closed automatically, thus the data is output correctly, while an unstopped JVM (like withmetafacture-playground) doesn't close all streams properly (in some cases). Here it is theLineRecorderwhich doesn't close its receiver.