ReaderBridge - used by the reader broker Sends acks to the pipe, receives data from the pipe
| 27 | // ReaderBridge - used by the reader broker |
| 28 | // Sends acks to the pipe, receives data from the pipe |
| 29 | type ReaderBridge struct { |
| 30 | pipe *DeliveryPipe |
| 31 | } |
| 32 | |
| 33 | func (b *ReaderBridge) StreamDataCommand(data wshrpc.CommandStreamData, opts *wshrpc.RpcOpts) error { |
| 34 | return fmt.Errorf("reader bridge should not send data") |
nothing calls this directly
no outgoing calls
no test coverage detected