diff options
author | murgatroid99 <mlumish@google.com> | 2015-08-11 17:28:42 -0700 |
---|---|---|
committer | murgatroid99 <mlumish@google.com> | 2015-08-11 17:28:42 -0700 |
commit | 9e2b7c81b10f79085df25a27fd2ab4b37e7d00e5 (patch) | |
tree | 6a98eedeb3353289bee6ea5b44af8cbb62e031fa /src/objective-c/RxLibrary/GRXBufferedPipe.h | |
parent | a16b5ef455c63a18929b4ef90945e90f01c1fd58 (diff) | |
parent | 9a2a3aecc8f7d667df0236df0367bb59a4ae37b1 (diff) |
Resolved merge conflicts with master
Diffstat (limited to 'src/objective-c/RxLibrary/GRXBufferedPipe.h')
-rw-r--r-- | src/objective-c/RxLibrary/GRXBufferedPipe.h | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/objective-c/RxLibrary/GRXBufferedPipe.h b/src/objective-c/RxLibrary/GRXBufferedPipe.h index b6296e1ed7..ca94ce275f 100644 --- a/src/objective-c/RxLibrary/GRXBufferedPipe.h +++ b/src/objective-c/RxLibrary/GRXBufferedPipe.h @@ -36,13 +36,11 @@ #import "GRXWriteable.h" #import "GRXWriter.h" -// A buffered pipe is a Writeable that also acts as a Writer (to whichever other writeable is passed -// to -startWithWriteable:). +// A buffered pipe is a Writer that also acts as a Writeable. // Once it is started, whatever values are written into it (via -writeValue:) will be propagated // 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 -// GRXWriterStateStarted. +// 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. // @@ -51,6 +49,9 @@ // pipe will keep buffering all data written to it, your application could run out of memory and // crash. If you want to react to flow control signals to prevent that, instead of using this class // you can implement an object that conforms to GRXWriter. +// +// Thread-safety: +// The methods of an object of this class should not be called concurrently from different threads. @interface GRXBufferedPipe : GRXWriter<GRXWriteable> // Convenience constructor. |