ezmsg.sigproc.util.message#

Message (AxisArray) utilities.

Also re-exports sample-message symbols from ezmsg.baseproc.util.message for backwards compatibility; new code should import those directly from ezmsg.baseproc instead.

Functions

has_samples_along(message, dim)[source]#

True iff dim is present in message with nonzero length.

Stricter than not is_empty_along(...): the dim must exist. Drain loops use this to decide whether a chunk is real output, so that a placeholder lacking the axis entirely (e.g. ResampleProcessor’s pre-init null template, dims=[""]) counts as “nothing ready” rather than a publishable chunk.

Parameters:
Return type:

bool

is_empty_along(message, dims)[source]#

True iff any of the named dims is present in message with zero length.

Publish gates use this instead of data.size == 0 so a message that is empty only along other axes — e.g. an upstream selection removed every channel while time samples remain — still flows downstream, preserving the stream’s cadence for consumers that align or merge multiple sources. Dims not present in the message are ignored.

Parameters:
Return type:

bool