Interface StreamUtils.OneTimeValve

  • Enclosing class:
    StreamUtils

    public static interface StreamUtils.OneTimeValve
    Similar to Source.maybe but doesn't rely on materialization. Can only be used once.
    • Method Detail

      • source

        <T> akka.stream.scaladsl.Source<T,​akka.NotUsed> source()
      • open

        void open()