embedBackendForwardStreamClient is the caller-facing side. Mirrors the server-side stream over the same channels.
| 815 | // embedBackendForwardStreamClient is the caller-facing side. Mirrors |
| 816 | // the server-side stream over the same channels. |
| 817 | type embedBackendForwardStreamClient struct { |
| 818 | ctx context.Context |
| 819 | reqs chan<- *pb.ForwardRequest |
| 820 | resps <-chan *pb.ForwardReply |
| 821 | srvDone <-chan error |
| 822 | once sync.Once |
| 823 | } |
| 824 | |
| 825 | func (e *embedBackendForwardStreamClient) Send(req *pb.ForwardRequest) error { |
| 826 | select { |
nothing calls this directly
no outgoing calls
no test coverage detected