From 65e44f0a9de387b60cf98ef1e7f384b2b284b932 Mon Sep 17 00:00:00 2001 From: Bryan Roe Date: Wed, 13 Feb 2019 15:57:02 -0800 Subject: [PATCH] Removed 'nocontinue' functionality from piped streams --- microscript/ILibDuktape_ReadableStream.c | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/microscript/ILibDuktape_ReadableStream.c b/microscript/ILibDuktape_ReadableStream.c index 1177502..6b1ed8d 100644 --- a/microscript/ILibDuktape_ReadableStream.c +++ b/microscript/ILibDuktape_ReadableStream.c @@ -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; } }