Struct epoxy_streams::Subscription

pub struct Subscription<T> { /* fields omitted */ }

A Subscription object ties a stream to a listener function such that the listener function is run whenever a new value is added to the stream. When the Subscription object is destroyed the listener function will stop getting called.

Examples

let stream_host: epoxy_streams::Sink<i32> = epoxy_streams::Sink::new();
let stream = stream_host.get_stream();
{
    let _subscription = stream.subscribe(|val| {val;});
    assert_eq!(stream.count_subscribers(), 1);
}
assert_eq!(stream.count_subscribers(), 0);

Trait Implementations

impl<T> Drop for Subscription<T>

fn drop(&mut self)

Executes the destructor for this type.