----------System.out:(1076/37257)----------
Seed from RandomFactory = 7753917535576667576L

[...]

start [2sec 885ms] Iteration 93
sink [2sec 885ms] Subscriber reads data with buffer size: 1
Subscription delay is 0 msec
Minimum total delay is 0 sec 0 ms
Request amount is 1 items
source [2sec 885ms] Publishing 1000 buffers of size 1 each
source [2sec 906ms] complete
end [2sec 906ms] Iteration 93

start [2sec 906ms] Iteration 94
sink [2sec 906ms] Subscriber reads data with buffer size: 1
Subscription delay is 0 msec
Minimum total delay is 0 sec 0 ms
Request amount is 1 items
source [2sec 906ms] Publishing 1000 buffers of size 1 each
Timeout refired 480 times

--------------------------------------------------------------------------------------

"MainThread" #15 prio=5 os_prio=0 cpu=902.53ms elapsed=485.83s allocated=30201K defined_classes=640 tid=0x0000fffe2c29ca40 nid=0x10ecfd waiting on condition [0x0000fffdeb1dc000]
   java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park(java.base@17.0.6-ea/Native Method)
- parking to wait for <0x00000000d0100158> (a java.util.concurrent.SubmissionPublisher$BufferedSubscription)
at java.util.concurrent.locks.LockSupport.park(java.base@17.0.6-ea/LockSupport.java:211)
at java.util.concurrent.SubmissionPublisher$BufferedSubscription.block(java.base@17.0.6-ea/SubmissionPublisher.java:1495)
at java.util.concurrent.ForkJoinPool.unmanagedBlock(java.base@17.0.6-ea/ForkJoinPool.java:3463)
at java.util.concurrent.ForkJoinPool.managedBlock(java.base@17.0.6-ea/ForkJoinPool.java:3434)
at java.util.concurrent.SubmissionPublisher$BufferedSubscription.awaitSpace(java.base@17.0.6-ea/SubmissionPublisher.java:1462)
at java.util.concurrent.SubmissionPublisher.retryOffer(java.base@17.0.6-ea/SubmissionPublisher.java:455)
at java.util.concurrent.SubmissionPublisher.doOffer(java.base@17.0.6-ea/SubmissionPublisher.java:432)
at java.util.concurrent.SubmissionPublisher.submit(java.base@17.0.6-ea/SubmissionPublisher.java:520)
at BufferingSubscriberTest.source(BufferingSubscriberTest.java:383)
at BufferingSubscriberTest.test(BufferingSubscriberTest.java:181)
at BufferingSubscriberTest.test(BufferingSubscriberTest.java:140)