raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=str #19291 add TestGraphStages for Sink and Source

Browse source
This commit is contained in:
Alexander Golubev 2016-01-26 11:47:30 -05:00
parent b9106da698
commit a10bba9c84
8 changed files with 118 additions and 121 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/Sinks.scala
View file

@ -245,7 +245,7 @@ private[akka] final class HeadOptionStage[T] extends GraphStageWithMaterializedV
/**
* INTERNAL API
*/
private[akka] class QueueSink[T]() extends GraphStageWithMaterializedValue[SinkShape[T], SinkQueue[T]] {
final private[stream] class QueueSink[T]() extends GraphStageWithMaterializedValue[SinkShape[T], SinkQueue[T]] {
type Requested[E] = Promise[Option[E]]
val in = Inlet[T]("queueSink.in")