File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
rest/jetty/src/main/scala/io/udash/rest/jetty Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -4,6 +4,7 @@ package rest.jetty
44import com .avsystem .commons .*
55import com .avsystem .commons .annotation .explicitGenerics
66import com .avsystem .commons .serialization .json .{JsonReader , JsonStringInput }
7+ import com .typesafe .scalalogging .LazyLogging
78import io .udash .rest .raw .*
89import io .udash .rest .util .Utils
910import io .udash .utils .URLEncoder
@@ -36,7 +37,7 @@ final class JettyRestClient(
3637 client : HttpClient ,
3738 defaultMaxResponseLength : Int = JettyRestClient .DefaultMaxResponseLength ,
3839 defaultTimeout : Duration = JettyRestClient .DefaultTimeout ,
39- ) {
40+ ) extends LazyLogging {
4041
4142 @ explicitGenerics
4243 def create [RestApi : RawRest .AsRealRpc : RestMetadata ](
@@ -145,6 +146,11 @@ final class JettyRestClient(
145146 case Ack .Continue => demander.run()
146147 case Ack .Stop => ()
147148 }
149+ .onCompleteNow {
150+ case Failure (ex) =>
151+ logger.error(" Unexpected error while processing streamed response chunk" , ex)
152+ case Success (_) =>
153+ }
148154 }
149155
150156 override def onComplete (result : Result ): Unit =
You can’t perform that action at this time.
0 commit comments