Note

Ophyd async is included on a provisional basis until the v1.0 release and may change API on minor release numbers before then

ophyd_async.fastcs.panda.PandaHDFWriter#

class ophyd_async.fastcs.panda.PandaHDFWriter(prefix: str, path_provider: PathProvider, name_provider: NameProvider, panda_data_block: DataBlock)[source]#

Methods

`close`
`collect_stream_docs`
`get_indices_written`
`observe_indices_written`	Wait until a specific index is ready to be collected
`open`	Retrieve and get descriptor of all PandA signals marked for capture
`wait_for_index`

async open(multiplier: int = 1) → Dict[str, DataKey][source]#: Retrieve and get descriptor of all PandA signals marked for capture

async wait_for_index(index: int, timeout: float | None = 10.0)[source]#

async observe_indices_written(timeout=10.0) → AsyncGenerator[int, None][source]#: Wait until a specific index is ready to be collected

async collect_stream_docs(indices_written: int) → AsyncIterator[Tuple[Literal['stream_resource'], StreamResource] | Tuple[Literal['stream_datum'], StreamDatum]][source]#