Method processSendData

pkg/streamclient/streambroker.go:167–177

(dataPk wshrpc.CommandStreamData)

}

func (b *Broker) processSendData(dataPk wshrpc.CommandStreamData) {
	b.lock.Lock()
	route := b.readerRoutes[dataPk.Id]
	b.lock.Unlock()

	opts := &wshrpc.RpcOpts{
		Route:      route,
		NoResponse: true,
	}
	b.rpcClient.StreamDataCommand(dataPk, opts)
}

func (b *Broker) processRecvData(dataPk wshrpc.CommandStreamData) {
	b.lock.Lock()