Add missing imports for Custom stream processing docs #25525

This commit is contained in:
jczuchnowski 2018-08-26 00:50:32 +02:00
parent 25079cb568
commit 7be4090ccd

View file

@ -40,9 +40,11 @@ class GraphStageDocSpec extends AkkaSpec {
"Demonstrate creation of GraphStage Source" in {
//#custom-source-example
import akka.stream.Attributes
import akka.stream.Outlet
import akka.stream.SourceShape
import akka.stream.Graph
import akka.stream.stage.GraphStage
import akka.stream.stage.GraphStageLogic
import akka.stream.stage.OutHandler
class NumbersSource extends GraphStage[SourceShape[Int]] {