-
Notifications
You must be signed in to change notification settings - Fork 3k
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
Feature/share notifier observable input #6430
base: master
Are you sure you want to change the base?
Feature/share notifier observable input #6430
Conversation
@@ -224,15 +231,15 @@ export function share<T>(options: ShareConfig<T> = {}): MonoTypeOperatorFunction | |||
dest.complete(); | |||
}, | |||
}); | |||
from(source).subscribe(connection); | |||
source.subscribe(connection); |
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.
i dont know why a from
was here, since it is an observable already, but if at all we should probably use innerFrom
?
CI fail seems unrelated |
ee727fe
to
520c4ce
Compare
anything left to move this forward? |
spec-dtslint/operators/share-spec.ts
Outdated
share({ | ||
resetOnError: () => new Promise(() => {}), | ||
resetOnComplete: () => new Promise(() => {}), | ||
resetOnRefCountZero: () => new Promise(() => {}), |
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.
Can we use something better than unresolved forever promises here? haha. I mean, I know it's just tests, but this is a leak.
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.
Will change
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.
Out of curiosity: is it indeed a leak? No references are being held to anything?
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.
One change requested. Otherwise, LGTM.
520c4ce
to
7834c31
Compare
review changes & rebased |
whats blocking this? |
Description:
Accept
ObservableInput
as return values from notifier factories and documentShareConfig
default values.