| 123 | } |
| 124 | |
| 125 | type httpSmartSubtransportStream struct { |
| 126 | owner *httpSmartSubtransport |
| 127 | req *http.Request |
| 128 | resp *http.Response |
| 129 | reader *io.PipeReader |
| 130 | writer *io.PipeWriter |
| 131 | sentRequest bool |
| 132 | recvReply sync.WaitGroup |
| 133 | httpError error |
| 134 | } |
| 135 | |
| 136 | func newManagedHttpStream(owner *httpSmartSubtransport, req *http.Request) *httpSmartSubtransportStream { |
| 137 | r, w := io.Pipe() |
nothing calls this directly
no outgoing calls
no test coverage detected