class HttpSink(http: HttpService) extends Sink[String] {
def apply(requestBody: String): Async[Unit] = {
http.put(requestBody).map(_ => ())
}
}
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment