public static interface StreamUtils.OneTimeValve
void
open()
<T> akka.stream.scaladsl.Source<T,akka.NotUsed>
source()
<T> akka.stream.scaladsl.Source<T,akka.NotUsed> source()
void open()