Skip to content

Conversation

danielcweber
Copy link
Collaborator

No description provided.

var safeObserver = SafeObserver<TSource>.Create(observer);
safeObserver.SetResource(subscription);
observer = safeObserver;
observer = safeObserver = SafeObserver<TSource>.Create(observer);
}

if (CurrentThreadScheduler.IsScheduleRequired)
{
Copy link
Collaborator Author

@danielcweber danielcweber Jun 18, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@akarnokd Can you please review again, it occured to me that on this path, the safeObserver is not assigned the resource. I guess I may have introduced a bug here.

Copy link
Collaborator Author

@danielcweber danielcweber Jun 18, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should be fixed by 0a964a5

Copy link
Collaborator

@akarnokd akarnokd left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It just skipped the safeObserver without affecting the dispose path. The unit tests usually fail when you make a mistake with the dispose chains.

@danielcweber danielcweber merged commit a8385a8 into dotnet:master Jun 19, 2018
@danielcweber danielcweber deleted the SaveAllocationInBasicProducer branch June 19, 2018 10:31
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants