// This isn't ideal to have, since the execution is synchronous, but this needs
// to be the case because the state transition has to be in blocking
// thread to avoid starving executor
let (tx, rx) = flume::bounded(1);
Changes introduced in this pull request:
refactor replay into replay_blocking and replay to avoid using channels
Summary of changes
To address the original comment
Changes introduced in this pull request:
replay
intoreplay_blocking
andreplay
to avoid using channelsReference issue to close (if applicable)
Closes
Other information and links
Change checklist