Generify the LoggingCallback

Author: gesellix

api-client/src/main/kotlin/de/gesellix/docker/remote/api/client/ExecApi.kt

@@ -246,7 +246,7 @@ class ExecApi(dockerClientConfig: DockerClientConfig = defaultClientConfig, prox
 
     // TODO the caller of #execStart() should decide about timeout and callback
     val timeout = Duration.of(1, ChronoUnit.HOURS)
-    val callback = LoggingCallback()
+    val callback = LoggingCallback<Frame>()
 
     when (localVarResponse.responseType) {
       ResponseType.Success -> {

api-client/src/main/kotlin/de/gesellix/docker/remote/api/client/ImageApi.kt

@@ -234,7 +234,7 @@ class ImageApi(dockerClientConfig: DockerClientConfig = defaultClientConfig, pro
     // from either `aux ID=sha:.*`,
     // or `stream Successfully built .*`,
     // or `stream Successfully tagged .*` messages.
-    val callback = LoggingCallback()
+    val callback = LoggingCallback<Any>()
 
     return when (localVarResponse.responseType) {
       ResponseType.Success -> {
@@ -568,7 +568,7 @@ class ImageApi(dockerClientConfig: DockerClientConfig = defaultClientConfig, pro
     )
 
     val timeout = Duration.of(1, ChronoUnit.MINUTES)
-    val callback = LoggingCallback()
+    val callback = LoggingCallback<Any>()
 
     return when (localVarResponse.responseType) {
       ResponseType.Success -> {
@@ -992,7 +992,7 @@ class ImageApi(dockerClientConfig: DockerClientConfig = defaultClientConfig, pro
     )
 
     val timeout = Duration.of(1, ChronoUnit.MINUTES)
-    val callback = LoggingCallback()
+    val callback = LoggingCallback<Any>()
 
     return when (localVarResponse.responseType) {
       ResponseType.Success -> {

api-client/src/main/kotlin/de/gesellix/docker/remote/api/core/LoggingCallback.kt

@@ -1,6 +1,6 @@
 package de.gesellix.docker.remote.api.core
 
-class LoggingCallback : StreamCallback<Any?> {
+class LoggingCallback<T> : StreamCallback<T?> {
 
   private val log by logger()
 
@@ -9,7 +9,7 @@ class LoggingCallback : StreamCallback<Any?> {
     job = cancellable
   }
 
-  override fun onNext(event: Any?) {
+  override fun onNext(event: T?) {
     log.info("$event")
   }
 }