Emits configurably shaped samples with configurable timestamps.
tag – emitted samples carry this tag
timestamps – async-iterable sequence of dattime.datetime instances
data – if callable: called with current timestamp to produce data; if not, taken literally as data