-
Notifications
You must be signed in to change notification settings - Fork 7.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add Single.defer() #3433
Add Single.defer() #3433
Conversation
return; | ||
} | ||
|
||
single.subscribe(singleSubscriber); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please notice that I'm not wrapping subscriber via Subscribers.wrap()
because SingleSubscriber
differs from Subscriber
, that's why I used subscribe
instead of unsafeSubscribe()
here.
If this should be changed, please comment.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
SingleSubscriber
doesn't have onStart
like Subscriber
so this is not a problem.
Please add unit test for callback returning null cases. |
80f711d
to
5f0e8f7
Compare
@akarnokd added Btw, I've used |
Func0 extends Callable so its okay. .:+1: |
👍 rebase please |
I'm still 👍 but please rebase. |
5f0e8f7
to
ee91a9d
Compare
Rebased! |
Thanks! Merged. |
thanks |
No description provided.