'Write a stream of minute data.
Parameters
data : iterable[(int, pd.DataFrame)]
The data to write. Each element should be a tuple of sid, data
where data has the following format:
columns : (\'open\', \'high\', \'low\', \'close\', \'volume\')
open : float64
high : float64
low  : float64
close : float64
volume : float64|int64
index : DatetimeIndex of market minutes.
A given sid may appear more than once in ``data``; however,
the dates must be strictly increasing.
show_progress : bool, optional
Whether or not to show a progress bar while writing.'

def write(self, data, show_progress=False, invalid_data_behavior='warn'):

    ctx = maybe_show_progress(data, show_progress=show_progress, item_show_func=(lambda e: (e if (e is None) else str(e[0]))), label='Merging    minute    equity    files:')
    write_sid = self.write_sid
    with ctx as it:
        for e in it:
            write_sid(invalid_data_behavior=invalid_data_behavior, *e)
