CombineStreams¶
- class baseband_tasks.combining.CombineStreams(ihs, task, method=None, *, atol=None, samples_per_frame=None)[source] [edit on github]¶
Bases:
baseband_tasks.base.Task
,baseband_tasks.combining.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
, andpolarization
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.- atol
Quantity
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.
- ihstuple of task or
See also
Concatenate
to concatenate streams along an existing axis
Stack
to stack streams together along a new axis