completeStreaming() without waiting throws exception

[georgi-l95]

As a block simulator operator
I want to be able to stop, without waiting fixed amount of time
So that I achieve cleaner code and faster test execution.

Problem

Currently we are waiting 100 ms before continuing with the flow of stopping the simulator, right after we call onComplete in the publisher client. This is because otherwise, stream is not closed on time and this is causing issues.
https://github.com/hashgraph/hedera-block-node/blob/v0.3.1/simulator/src/main/java/com/hedera/block/simulator/grpc/impl/PublishStreamGrpcClientImpl.java#L160

Solution

Find a suitable solution for this behavior.

[jsync-swirlds]

Just a thought.
Could we submit a Task to the common fork/join pool (ForkJoinPool.commonPool() ) and let it complete asynchronously?
That task, then, can check stream status and take as long as it needs to (but no longer) without the main thread having to wait.