Struct timely::logging::EventPusherTee

pub struct EventPusherTee<T: PartialOrder + Ord + Default + Clone + 'static, D: Clone> { /* fields omitted */ }

An EventPusher that supports dynamically adding new EventPushers.

The tee maintains the frontier as the stream of events passes by. When a new pusher arrives it advances the frontier to the current value, and starts to forward events to it as well.

Methods

impl<T: PartialOrder + Ord + Default + Clone + 'static, D: Clone> EventPusherTee<T, D>

pub fn new() -> Self

Construct a new tee with no subscribers.

pub fn subscribe(&mut self, listener: Box<EventPusher<T, D> + Send>)

Subscribe to this tee.

Trait Implementations

impl<T: PartialOrder + Ord + Default + Clone, D: Clone> EventPusher<T, D> for EventPusherTee<T, D>

fn push(&mut self, event: Event<T, D>)

Provides a new Event<T, D> to the pusher.