close()#

ChannelBufferPublisher.close() → None[source]#

Close the publisher and clear all buffers with thread synchronization.