Skip to content

Commit 279ab2f

Browse files
authored
Merge pull request #100 from navikt/task/closeable-grpc-client
Make InntektHenter closable
2 parents 4024202 + ee11f0d commit 279ab2f

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

dp-inntekt-grpc/src/main/kotlin/no/nav/dagpenger/inntekt/rpc/InntektHenterWrapper.kt

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ import no.nav.dagpenger.events.inntekt.v1.Inntekt
1818
import no.nav.dagpenger.events.inntekt.v1.SpesifisertInntekt
1919
import no.nav.dagpenger.events.moshiInstance
2020

21-
interface InntektHenter {
21+
interface InntektHenter : Closeable {
2222
suspend fun hentSpesifisertInntekt(inntektId: String): SpesifisertInntekt
2323
suspend fun hentKlassifisertInntekt(inntektId: String): Inntekt
2424
}
@@ -39,11 +39,15 @@ class InntektHenterWrapper private constructor(
3939
.executor(Dispatchers.IO.asExecutor())
4040
.usePlaintext().build()
4141
)
42+
43+
override fun close() {
44+
client.close()
45+
}
4246
}
4347

4448
internal class InntektHenterClient constructor(
4549
private val channel: ManagedChannel
46-
) : Closeable, InntektHenter {
50+
) : InntektHenter {
4751

4852
companion object {
4953
private val spesifisertInntektAdapter = moshiInstance.adapter(SpesifisertInntekt::class.java)!!

0 commit comments

Comments
 (0)