hashgraph / hedera-block-node

New Block Node services
Apache License 2.0
24 stars 3 forks source link

`completeStreaming()` without waiting throws exception #352

Open georgi-l95 opened 1 week ago

georgi-l95 commented 1 week ago

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.

Solution

Find a suitable solution for this behavior.