<@U0BLPSJAK> What is this reference to `copyToSusp...
# ktorr
rocketraman
08/14/2018, 10:45 PM@Deactivated User What is this reference to
copyToSuspendcopyTod
Deactivated User
08/14/2018, 11:26 PMWell. It is just an extension method defined below in that page too. I guess I added the suspend suffix to make it clear that was asynchronous. But I probably i could just remove that suffix
r
rocketraman
08/14/2018, 11:28 PMAh, I didn't even see that... I thought it wasn't really possible to create a suspending function reading/writing streams, as streams are always blocking. There was some discussion about this in #coroutines .
rocketraman
08/14/2018, 11:29 PMi.e. there is no way to guarantee that that call to
out.write(buffer, 0, bytes)d
Deactivated User
08/14/2018, 11:48 PMActually, that extension method does the blocking calls in another thread. So yes, it is blocking, but it blocks another thread.
r
rocketraman
08/14/2018, 11:48 PMVia the
ioCoroutineDispatcherd
Deactivated User
08/14/2018, 11:48 PMYes. That dispatcher uses a thread pool just for blocking I/O
r
rocketraman
08/14/2018, 11:49 PMCool. I didn't realize that was already available -- I thought it was still being worked on.
d
Deactivated User
08/14/2018, 11:50 PMAnd it makes copy in chunks. So after each suspension, for each thread in that dispatcher, it can multiplex other synchronous reads
r
rocketraman
08/14/2018, 11:50 PMHmm, the issue is still open... https://github.com/Kotlin/kotlinx.coroutines/issues/79
rocketraman
08/14/2018, 11:52 PMAh, I see
IOCoroutineDispatcherrocketraman
08/14/2018, 11:52 PMCool stuff, thanks.
👍 1
d
Deactivated User
08/14/2018, 11:52 PMDeactivated User
08/14/2018, 11:52 PMyes
6 Views