Reads and writes the queue to a text file
Reads and writes the queue to a text file
new()Creates a TextFileSource
TextFileSource$new(filePath = tempFileGenerator()())filePathThe path to the file.
pop()removes n items from the source and returns them
TextFileSource$pop(n = -1)nThe number of records to pop (-1 indicates all available).
push()Adds an item to the source.
TextFileSource$push(msg, obj)msgA string indicating the signal.
objThe object to associate with the signal.
destroy()Cleans up source after use.
TextFileSource$destroy()
clone()The objects of this class are cloneable with this method.
TextFileSource$clone(deep = FALSE)deepWhether to make a deep clone.
A wrapper around txtq. This object saves signals
and associated objects to and queue, and retrieves them
for processing.