parent
0bf0f1a955
commit
1d36879e53
1 changed files with 3 additions and 0 deletions
|
|
@ -90,8 +90,11 @@ class GraphStageDocSpec extends AkkaSpec {
|
|||
|
||||
"Demonstrate creation of GraphStage Sink" in {
|
||||
//#custom-sink-example
|
||||
import akka.stream.Attributes
|
||||
import akka.stream.Inlet
|
||||
import akka.stream.SinkShape
|
||||
import akka.stream.stage.GraphStage
|
||||
import akka.stream.stage.GraphStageLogic
|
||||
import akka.stream.stage.InHandler
|
||||
|
||||
class StdoutSink extends GraphStage[SinkShape[Int]] {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue