fix: reader don't exit in some cases.

[zey1996]

I notice cdc can't change to new generation in some case.
I think it's a bug.

https://github.com/zey1996/scylla-cdc-go/blob/e99bcf197b49a2603acc317875f5c6d62db9a0e2/stream_batch.go#L160

when we close reader, sbr.interruptCh be writed a struct. but ,if sbr.reachedEndOfTheGeneration(wnd.begin) return true.
the reader will never be close.

[dkropachev]

Now, if you call sbr.close() with timestamp from future, it will spin in the following cycle without break consuming all cpu available:

scylla-cdc-go/stream_batch.go

Lines 153 to 164 in c4f1a40

	for {
	select {
	case <-ctx.Done():
	return ctx.Err()
	case <-time.After(time.Until(delayUntil)):
	break delay
	case <-sbr.interruptCh:
	if sbr.reachedEndOfTheGeneration(wnd.begin) {
	break outer
	}
	}
	}

[dkropachev]

I notice cdc can't change to new generation in some case. I think it's a bug.

Do you have any steps how to reproduce it, logs maybe ?

when we close reader, sbr.interruptCh be writed a struct. but ,if sbr.reachedEndOfTheGeneration(wnd.begin) return true. the reader will never be close.

Could you please clarify this statement, I don't see any pathway for it to happen.