Commit4ce7dd6

committed

Fix uploading in OKHttp3 hanging forever when internet is cut off.

1 parente66052f commit4ce7dd6Copy full SHA for 4ce7dd6

File tree

-2

lines changed

-2

lines changed

Lines changed: 5 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,7 @@ public OutputStream getBody() {`
`214`	`214`	`PipedRequestBodypipedBody =newPipedRequestBody();`
`215`	`215`	`setBody(pipedBody);`
`216`	`216`
`217`		`-this.callback =newAsyncCallback();`
	`217`	`+this.callback =newAsyncCallback(pipedBody);`
`218`	`218`	`this.call =client.newCall(request.build());`
`219`	`219`	`// enqueue the call (async call execution). This allows us to provide streaming uploads.`
`220`	`220`	`call.enqueue(callback);`
`@@ -288,10 +288,12 @@ public Response finish() throws IOException {`
`288`	`288`	`}`
`289`	`289`
`290`	`290`	`publicstaticfinalclassAsyncCallbackimplementsCallback {`
	`291`	`+privatePipedRequestBodybody;`
`291`	`292`	`privateIOExceptionerror;`
`292`	`293`	`privateokhttp3.Responseresponse;`
`293`	`294`
`294`		`-privateAsyncCallback() {`
	`295`	`+privateAsyncCallback(PipedRequestBodybody) {`
	`296`	`+this.body =body;`
`295`	`297`	`this.error =null;`
`296`	`298`	`this.response =null;`
`297`	`299`	`}`
`@@ -314,6 +316,7 @@ public synchronized okhttp3.Response getResponse() throws IOException {`
`314`	`316`	`@Override`
`315`	`317`	`publicsynchronizedvoidonFailure(Callcall,IOExceptionex) {`
`316`	`318`	`this.error =ex;`
	`319`	`+this.body.close();`
`317`	`320`	`notifyAll();`
`318`	`321`	`}`
`319`	`322`

Comments

(0)