Struct BrokerDataSender

cmd/test-streammanager/main-test-streammanager.go:208–210 · view source on GitHub ↗

BrokerDataSender implements DataSender interface

Source from the content-addressed store, hash-verified

206
207	// BrokerDataSender implements DataSender interface
208	type BrokerDataSender struct {
209	broker *streamclient.Broker
210	}
211
212	func (s *BrokerDataSender) SendData(dataPk wshrpc.CommandStreamData) {
213	s.broker.SendData(dataPk)

nothing calls this directly

no outgoing calls

no test coverage detected