Skip to content

Commit

Permalink
Removed synthentic accessor from auto disposables and recording obser…
Browse files Browse the repository at this point in the history
…ver (#103)

Added comment to annotate that the method is private
  • Loading branch information
bangarharshit authored and ZacSweers committed Oct 8, 2017
1 parent 6d0a73d commit 1c94067
Show file tree
Hide file tree
Showing 6 changed files with 24 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ private void lazyDispose() {
}
}

private void callMainSubscribeIfNecessary(Disposable d) {
/* private */
void callMainSubscribeIfNecessary(Disposable d) {
// If we've never actually called the downstream onSubscribe (i.e. requested immediately in
// onSubscribe and had a terminal event), we need to still send an empty disposable instance
// to abide by the Observer contract.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ private void lazyDispose() {
}
}

private void callMainSubscribeIfNecessary(Disposable d) {
/* private */
void callMainSubscribeIfNecessary(Disposable d) {
// If we've never actually called the downstream onSubscribe (i.e. requested immediately in
// onSubscribe and had a terminal event), we need to still send an empty disposable instance
// to abide by the Observer contract.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ private void lazyDispose() {
}
}

private void callMainSubscribeIfNecessary(Disposable d) {
/* private */
void callMainSubscribeIfNecessary(Disposable d) {
// If we've never actually called the downstream onSubscribe (i.e. requested immediately in
// onSubscribe and had a terminal event), we need to still send an empty disposable instance
// to abide by the Observer contract.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ private void lazyDispose() {
}
}

private void callMainSubscribeIfNecessary(Disposable d) {
/* private */
void callMainSubscribeIfNecessary(Disposable d) {
// If we've never actually called the downstream onSubscribe (i.e. requested immediately in
// onSubscribe and had a terminal event), we need to still send an empty disposable instance
// to abide by the Observer contract.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,8 @@ private void lazyCancel() {
}
}

private void callMainSubscribeIfNecessary(Subscription s) {
/* private */
void callMainSubscribeIfNecessary(Subscription s) {
// If we've never actually started the upstream subscription (i.e. requested immediately in
// onSubscribe and had a terminal event), we need to still send an empty subscription instance
// to abide by the Subscriber contract.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,8 @@ public void assertNoMoreEvents() {
private final class OnNext {
final T value;

private OnNext(T value) {
/* private */
OnNext(T value) {
this.value = value;
}

Expand All @@ -141,9 +142,11 @@ private static final class OnCompleted {
}

private static final class OnError {
private final Throwable throwable;
/* private */
final Throwable throwable;

private OnError(Throwable throwable) {
/* private */
OnError(Throwable throwable) {
this.throwable = throwable;
}

Expand All @@ -153,9 +156,11 @@ private OnError(Throwable throwable) {
}

private static final class OnSubscribe {
private final Disposable disposable;
/* private */
final Disposable disposable;

private OnSubscribe(Disposable disposable) {
/* private */
OnSubscribe(Disposable disposable) {
this.disposable = disposable;
}

Expand All @@ -165,9 +170,11 @@ private OnSubscribe(Disposable disposable) {
}

private final class OnSuccess {
private final T value;
/* private */
final T value;

private OnSuccess(T value) {
/* private */
OnSuccess(T value) {
this.value = value;
}

Expand Down

0 comments on commit 1c94067

Please sign in to comment.