skip_events
Lets the pipeline skips the provided number of events.
Parameters
- events_to_skip:
int
The number of events to skip before continuing the flow.
Example
from pybeamline.sources import log_source
from pybeamline.utils.skip_events import skip_events
from pybeamline.sinks.print_sink import print_sink
log_source(["ABC", "DEF"]).pipe(
skip_events(2)
).subscribe(print_sink())
Output: