Package akka.http.impl.util

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 Summary

    Modifier and Type
    Method
    Description
    void
    open()
     
    <T> akka.stream.scaladsl.Source<T,akka.NotUsed>
    source()
     

  • Method Details

    • source

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

    • open

      void open()