CombineStreams

class baseband_tasks.combining.CombineStreams(ihs, task, method=None, *, atol=None, samples_per_frame=None)

Bases: Task, CombineStreamsBase

Combining streams using a callable.

Parameters:

ihstuple of task or baseband stream readers

Input data streams.

taskcallable

The function or method-like callable. The task must work with any number of data samples and combine the samples only. It will also be applied to the frequency, sideband, and polarization attributes of the underlying stream (if present).

methodbool, optional

Whether task is a method (two arguments) or a function (one argument). Default: inferred by inspection.

atolQuantity

Tolerance in units of time within which streams should be considered aligned. By default, the lesser of 1 ns or 0.01 sample.

samples_per_frameint, optional

Number of samples which should be fed to the function in one go. If not given, by default the number from the first underlying file. Useful mostly to change a possibly very large number.

See also

Concatenate

to concatenate streams along an existing axis

Stack

to stack streams together along a new axis