diff options
| author |  Jorge Canizales <jcanizales@google.com> | 2015-05-18 17:12:41 -0700 |
|---|---|---|
| committer | Jorge Canizales <jcanizales@google.com> | 2015-05-19 16:05:31 -0700 |
| commit | a90a9c395d86b5f1e6b123ae25de14c7f0362040 (patch) | |
| tree | 2e87fd10bf17843fa2264452fb075af87839541f /src/objective-c/RxLibrary/GRXBufferedPipe.m | |
| parent | 421f6c9488795a1a125770f258b9cf4feef4f293 (diff) | |
s/didReceiveValue/writeValue
Diffstat (limited to 'src/objective-c/RxLibrary/GRXBufferedPipe.m')
| -rw-r--r-- | src/objective-c/RxLibrary/GRXBufferedPipe.m | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/objective-c/RxLibrary/GRXBufferedPipe.m b/src/objective-c/RxLibrary/GRXBufferedPipe.m index e1295cef8a..0230f14c36 100644 --- a/src/objective-c/RxLibrary/GRXBufferedPipe.m +++ b/src/objective-c/RxLibrary/GRXBufferedPipe.m @@ -62,7 +62,7 @@ - (void)writeBufferUntilPausedOrStopped { while (_state == GRXWriterStateStarted && _queue.count > 0) { - [_writeable didReceiveValue:[self popValue]]; + [_writeable writeValue:[self popValue]]; } if (_inputIsFinished && _queue.count == 0) { // Our writer finished normally while we were paused or not-started-yet. @@ -77,10 +77,10 @@ return _state == GRXWriterStateStarted && _queue.count == 0; } -- (void)didReceiveValue:(id)value { +- (void)writeValue:(id)value { if (self.shouldFastForward) { // Skip the queue. - [_writeable didReceiveValue:value]; + [_writeable writeValue:value]; } else { // Even if we're paused and with enqueued values, we can't excert back-pressure to our writer. // So just buffer the new value. |