Skip to content

Instantly share code, notes, and snippets.

/post.scala

Created Apr 18, 2017
Embed
What would you like to do?
the description for this gist
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