diff options
| author |  Michael Lumish <mlumish@google.com> | 2015-05-20 08:38:41 -0700 |
|---|---|---|
| committer | Michael Lumish <mlumish@google.com> | 2015-05-20 08:38:41 -0700 |
| commit | 958b0b9e7a5f0a95537176c5e25a6934f0b892a3 (patch) | |
| tree | 37d6418a660a61b05094dd35ba38d8ee46dc7fac /src/objective-c/RxLibrary/GRXBufferedPipe.m | |
| parent | 4a0b2e2f8b5475775e62cf4121e4990f07b7c187 (diff) | |
| parent | b2c300c4be537c54f3adcaf3ca190b9bce002fab (diff) | |
Merge pull request #1664 from jcanizales/renames-grx-writeable-methods
Rename GRXWriteable methods
Diffstat (limited to 'src/objective-c/RxLibrary/GRXBufferedPipe.m')
| -rw-r--r-- | src/objective-c/RxLibrary/GRXBufferedPipe.m | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/objective-c/RxLibrary/GRXBufferedPipe.m b/src/objective-c/RxLibrary/GRXBufferedPipe.m index 3ef470f89f..4820c84af0 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. @@ -92,7 +92,7 @@ } } -- (void)didFinishWithError:(NSError *)errorOrNil { +- (void)writesFinishedWithError:(NSError *)errorOrNil { _inputIsFinished = YES; _errorOrNil = errorOrNil; if (errorOrNil || self.shouldFastForward) { @@ -140,7 +140,7 @@ - (void)finishWithError:(NSError *)errorOrNil { id<GRXWriteable> writeable = _writeable; self.state = GRXWriterStateFinished; - [writeable didFinishWithError:errorOrNil]; + [writeable writesFinishedWithError:errorOrNil]; } @end |