MeshCentral/MeshAgent
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshAgent synced 2025-12-24 04:04:31 +00:00
Code Issues Releases Wiki Activity

Removed 'nocontinue' functionality from piped streams

Browse Source
This commit is contained in:
Bryan Roe
2019-02-13 15:57:02 -08:00
parent 353b4b2181
commit 65e44f0a9d
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
microscript/ILibDuktape_ReadableStream.c
View File

@@ -276,7 +276,6 @@ int ILibDuktape_readableStream_WriteDataEx(ILibDuktape_readableStream *stream, i
{
ILibDuktape_readableStream_nextWriteablePipe *w;
int dispatchedNonNative = 0;
int noContinue = 0;
int dispatched = 0;
int needPause = 0;
@@ -321,13 +320,12 @@ int ILibDuktape_readableStream_WriteDataEx(ILibDuktape_readableStream *stream, i
case ILibTransport_DoneState_COMPLETE:
ws->OnWriteFlushEx = NULL;
ws->OnWriteFlushEx_User = NULL;
if (ILibDuktape_readableStream_WriteData_Flush(ws, stream)) { noContinue = 1; }
if (ILibDuktape_readableStream_WriteData_Flush(ws, stream)) { }
break;
case ILibTransport_DoneState_ERROR:
if (ILibDuktape_readableStream_WriteData_Flush(ws, stream)) { noContinue = 1; }
if (ILibDuktape_readableStream_WriteData_Flush(ws, stream)) { }
break;
}
if (noContinue != 0) { break; }
}
else if (w->writableStream != NULL && dispatchedNonNative == 0)
{
@@ -351,14 +349,12 @@ int ILibDuktape_readableStream_WriteDataEx(ILibDuktape_readableStream *stream, i
needPause = 1;
break;
case 1: // Complete
noContinue = 1;
break;
default: // NOP
break;
}
}
}
if (noContinue != 0) { break; }
w = w->next;
}
}