in_memory_device_manager

messageflux.iodevices.in_memory_device.in_memory_device_manager

InMemoryDeviceManager

InMemoryDeviceManager(**kwargs)

Bases: InputDeviceManager[InMemoryInputDevice], OutputDeviceManager[InMemoryOutputDevice]

the in memory device manager. it serves as both input and output device manager. notice that the messages are shared only within the same manager!

InMemoryInputDevice

InMemoryInputDevice(
    manager, name, queue, queue_not_empty_condition
)

Bases: InputDevice['InMemoryDeviceManager']

an input device which is stored in memory

InMemoryTransaction

InMemoryTransaction(device, message)

Bases: InputTransaction

a transaction object for the in memory device

InMemoryOutputDevice

InMemoryOutputDevice(
    manager, name, queue, queue_not_empty_condition
)

Bases: OutputDevice['InMemoryDeviceManager']

an output device which is stored in memory