383ea0326ae103b5d5e0b62ed9c3cb18510c5b9e,distributed/comm/tcp.py,TCP,write,#TCP#Any#Any#Any#,229

Before Change

                    // ("If write is called again before that Future has resolved,
                    //   the previous future will be orphaned and will never resolve")
                    if frame_bytes:
                        future = stream.write(frame)
                        bytes_since_last_yield += frame_bytes
                        if bytes_since_last_yield > 32e6:
                            await future
                            bytes_since_last_yield = 0

After Change

                    stream._total_write_index += each_frame_nbytes

            // start writing frames
            stream.write(b"")
        except StreamClosedError as e:
            self.stream = None
            self._closed = True

Instances