class HttpSink(http: HttpService) extends Sink[String] {
def apply(requestBody: String): Async[Unit] = {
http.put(requestBody).map(_ => ())
}
}
Created
May 28, 2018 06:08
-
-
Save wjlow/d30347ffafeea39143889a507d539676 to your computer and use it in GitHub Desktop.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment