Skip to content

Instantly share code, notes, and snippets.

/post.scala

Created April 18, 2017 13:11
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save anonymous/e4eb5cb4d4d5663b3e67b724e1afcabf to your computer and use it in GitHub Desktop.
Save anonymous/e4eb5cb4d4d5663b3e67b724e1afcabf to your computer and use it in GitHub Desktop.
Download ZIP
the description for this gist
Raw
post.scala
val source = Source(List(ByteString("abc"), ByteString("def")))
val proxyStage = new HttpsProxyStage0("hostname", 8888)
val proxyFlow = BidiFlow.fromGraph(proxyStage)
val flow = Flow[ByteString].statefulMapConcat { () =>
var firstElement =
(input: ByteString) => {
if(firstElement) {
firstElement = false
List(ByteString("OK"))
} else {
List(input)
}
}
val wholeFlow = proxyFlow.join(flow)
source.via(wholeFlow).runForeach(element => println("Sink received: " + element.utf8String))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment