close()#

DequeInMemoryPublisher.close() → None#

Close the publisher and clear all buffers with thread synchronization.