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.m | |
| parent | bea9fe4b4e4ec5477fffb277620518711fdde6bd (diff) | |
Some fixes for tests and change contract
Diffstat (limited to 'src/objective-c/RxLibrary/GRXBufferedPipe.m')
| -rw-r--r-- | src/objective-c/RxLibrary/GRXBufferedPipe.m | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/objective-c/RxLibrary/GRXBufferedPipe.m b/src/objective-c/RxLibrary/GRXBufferedPipe.m index 6433b62578..99cb0ad971 100644 --- a/src/objective-c/RxLibrary/GRXBufferedPipe.m +++ b/src/objective-c/RxLibrary/GRXBufferedPipe.m @@ -60,7 +60,7 @@ - (void)writesFinishedWithError:(NSError *)errorOrNil { __weak GRXBufferedPipe *weakSelf = self; dispatch_async(_writeQueue, ^{ - [weakSelf finishWithError:nil]; + [weakSelf finishWithError:errorOrNil]; }); } @@ -88,8 +88,7 @@ } return; case GRXWriterStateStarted: - if (_state == GRXWriterStatePaused || - _state == GRXWriterStateNotStarted) { + if (_state == GRXWriterStatePaused) { _state = newState; dispatch_resume(_writeQueue); } @@ -102,7 +101,8 @@ - (void)startWithWriteable:(id<GRXWriteable>)writeable { self.writeable = writeable; - self.state = GRXWriterStateStarted; + _state = GRXWriterStateStarted; + dispatch_resume(_writeQueue); } - (void)finishWithError:(NSError *)errorOrNil { |