Method cleanupWriter

pkg/streamclient/streambroker.go:239–245

(streamId string)

}

func (b *Broker) cleanupWriter(streamId string) {
	b.lock.Lock()
	defer b.lock.Unlock()

	delete(b.writers, streamId)
	delete(b.writerRoutes, streamId)
}