Replaced runnable parameter type from TranscriberOnFlush to Runnable of
afterNextTrigger of connection.

Signed-off-by: Jakob Brandsborg Ehmsen <jakobehmsen.github@gmail.com>