pub fn resume_position<T: DeserializeOwned>(
from: Option<&LogCursor>,
sink: &mut LogSink,
keep: impl FnOnce(&T) -> bool,
) -> PluginResult<Option<T>>pub fn resume_position<T: DeserializeOwned>(
from: Option<&LogCursor>,
sink: &mut LogSink,
keep: impl FnOnce(&T) -> bool,
) -> PluginResult<Option<T>>