Method Close

pkg/streamclient/streambroker.go:223–228

()

}

func (b *Broker) Close() {
	b.sendQueue.Close(false)
	b.recvQueue.Close(false)
	b.sendQueue.Wait()
	b.recvQueue.Wait()
}

func (b *Broker) cleanupReader(streamId string) {
	b.lock.Lock()