diff --git a/metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/CloseSuppressor.java b/metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/CloseSuppressor.java index cb9fb08f5..399b731b8 100644 --- a/metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/CloseSuppressor.java +++ b/metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/CloseSuppressor.java @@ -33,7 +33,7 @@ * @author Markus Geipel * */ -@Description("") +@Description("Blocks close-stream events until a given number of close-stream events have been received.") @In(Object.class) @Out(Object.class) @FluxCommand("wait-for-inputs")