()
| 168 | func (*mockUploadStream) CloseSend() error { panic(errUnimplemented) } |
| 169 | func (*mockUploadStream) Close() error { panic(errUnimplemented) } |
| 170 | func (m *mockUploadStream) isDone() bool { |
| 171 | select { |
| 172 | case <-m.done: |
| 173 | return true |
| 174 | default: |
| 175 | return false |
| 176 | } |
| 177 | } |
| 178 | |
| 179 | func newMockUploadStream(up *sdkproto.DataUpload, chunks ...*sdkproto.ChunkPiece) *mockUploadStream { |
| 180 | stream := &mockUploadStream{ |
no outgoing calls
no test coverage detected