ISynchronizer
Interface which provides the data to stream to the algorithm
stream_data(
cancellation_token: CancellationToken,
) -> Iterable[TimeSlice]
Returns an enumerable which provides the data to stream to the algorithm