Error logged in tests: Pool has been shut down

[johanandren]

I don't think this is anything serious, but would be good to investigate and silence, shut down orderly, if possible:

When running grpc-projection integration tests, after test complete, this is logged:

[ERROR] [12/20/2023 14:37:15.860] [ReplicationIntegrationSpecA-akka.actor.default-dispatcher-23] [akka.grpc.scaladsl.GrpcExceptionHandler(akka://ReplicationIntegrationSpecB)] Unhandled error: [Pool has been shut down]
reactor.pool.PoolShutdownException: Pool has been shut down
	at reactor.pool.SimpleDequePool.doAcquire(SimpleDequePool.java:294)
	at reactor.pool.AbstractPool$Borrower.request(AbstractPool.java:430)
	at reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194)
	at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2305)
	at reactor.core.publisher.SerializedSubscriber.request(SerializedSubscriber.java:151)
	at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136)
	at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2341)
	at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onSubscribe(FluxOnErrorResume.java:74)
	at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onSubscribe(FluxContextWrite.java:101)
	at reactor.core.publisher.SerializedSubscriber.onSubscribe(SerializedSubscriber.java:65)
	at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.onSubscribe(FluxTimeout.java:154)
	at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117)
	at reactor.pool.SimpleDequePool$QueueBorrowerMono.subscribe(SimpleDequePool.java:722)
	at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64)
	at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53)
	at reactor.core.publisher.FluxRetry$RetrySubscriber.resubscribe(FluxRetry.java:117)
	at reactor.core.publisher.MonoRetry.subscribeOrReturn(MonoRetry.java:50)
	at reactor.core.publisher.Mono.subscribe(Mono.java:4480)
	at reactor.core.publisher.Mono.subscribeWith(Mono.java:4561)
	at reactor.core.publisher.Mono.toFuture(Mono.java:5073)
	at akka.persistence.r2dbc.internal.R2dbcExecutor$PublisherOps$.asFuture$extension(R2dbcExecutor.scala:43)
	at akka.persistence.r2dbc.internal.R2dbcExecutor.getConnection(R2dbcExecutor.scala:126)
	at akka.persistence.r2dbc.internal.R2dbcExecutor.select(R2dbcExecutor.scala:235)
	at akka.persistence.r2dbc.internal.postgres.PostgresQueryDao.rowsBySlices(PostgresQueryDao.scala:195)
	at akka.persistence.r2dbc.internal.BySliceQuery.nextQuery$2(BySliceQuery.scala:459)
	at akka.persistence.r2dbc.internal.BySliceQuery.$anonfun$liveBySlices$6(BySliceQuery.scala:470)
	at akka.persistence.r2dbc.internal.ContinuousQuery$$anon$1.runNextQuery(ContinuousQuery.scala:126)
	at akka.persistence.r2dbc.internal.ContinuousQuery$$anon$1.akka$persistence$r2dbc$internal$ContinuousQuery$$anon$$next(ContinuousQuery.scala:118)
	at akka.persistence.r2dbc.internal.ContinuousQuery$$anon$1.onTimer(ContinuousQuery.scala:101)
	at akka.stream.stage.TimerGraphStageLogic.onInternalTimer(GraphStage.scala:1659)