akka.stream.impl

Interface QueueSource.Input<T>

All Known Implementing Classes:

QueueSource.Completion$, QueueSource.Failure, QueueSource.Offer

Enclosing class:

QueueSource<T>

public static interface QueueSource.Input<T>