org.apache.pekko.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 and Description
void	open()
<T> org.apache.pekko.stream.scaladsl.Source<T,org.apache.pekko.NotUsed>	source()

Method Detail

source

<T> org.apache.pekko.stream.scaladsl.Source<T,org.apache.pekko.NotUsed> source()

open

void open()