diff options
| author |  Muxi Yan <mxyan@google.com> | 2017-06-26 17:25:01 -0700 |
|---|---|---|
| committer | Muxi Yan <mxyan@google.com> | 2017-06-26 17:25:01 -0700 |
| commit | c05d1b41c285c8e65e305c512323b596cd4a1c16 (patch) | |
| tree | 5dca8b00905ea6747c4a7be41d58e30d68b69d51 /src/objective-c/RxLibrary/GRXBufferedPipe.h | |
| parent | bea9fe4b4e4ec5477fffb277620518711fdde6bd (diff) | |
Some fixes for tests and change contract
Diffstat (limited to 'src/objective-c/RxLibrary/GRXBufferedPipe.h')
| -rw-r--r-- | src/objective-c/RxLibrary/GRXBufferedPipe.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/objective-c/RxLibrary/GRXBufferedPipe.h b/src/objective-c/RxLibrary/GRXBufferedPipe.h index bd7d4ad691..a871ea895a 100644 --- a/src/objective-c/RxLibrary/GRXBufferedPipe.h +++ b/src/objective-c/RxLibrary/GRXBufferedPipe.h @@ -27,8 +27,8 @@ * immediately, unless flow control prevents it. * If it is throttled and keeps receiving values, as well as if it receives values before being * started, it will buffer them and propagate them in order as soon as its state becomes Started. - * If it receives an error (via -writesFinishedWithError:), it will drop any buffered values and - * propagate the error immediately. + * If it receives an end of stream (via -writesFinishedWithError:), it will buffer the EOS after the + * last buffered value and issue it to the writeable after all buffered values are issued. * * Beware that a pipe of this type can't prevent receiving more values when it is paused (for * example if used to write data to a congested network connection). Because in such situations the |