Skip to content

Commit 6077abe

Browse files
Merge pull request #927 from benjchristensen/test-subscriber-last-seen-thread
TestSubscriber lastSeenThread
2 parents 1ae4053 + a0c8009 commit 6077abe

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

rxjava-core/src/main/java/rx/observers/TestSubscriber.java

+2
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ public void onNext(T t) {
6464
@Override
6565
public void onCompleted() {
6666
try {
67+
lastSeenThread = Thread.currentThread();
6768
testObserver.onCompleted();
6869
} finally {
6970
latch.countDown();
@@ -77,6 +78,7 @@ public List<Notification<T>> getOnCompletedEvents() {
7778
@Override
7879
public void onError(Throwable e) {
7980
try {
81+
lastSeenThread = Thread.currentThread();
8082
testObserver.onError(e);
8183
} finally {
8284
latch.countDown();

0 commit comments

Comments
 (0)