Michel Feinstein

Do we have any updates on this? There's a big warning in the git lfs webside about a security update, people will update and think the binaries will be safe...

I see... unfortunately I am not familiar with it either :/

Hmm I think I misunderstood what "shutsdown" means on the docs. I thought it would shutdown until someone subscribes again. Still what the logs show me is that the stream...

Managing the stream was my plan B, I am just a bit disappointed there isn't an operator for something as simple as this. I will try to adapt your example...

@brianegan as far I have read Publish/Connect doesn't buffer the last value, so is your recommendation buffering it?

Never mind, I can see it does buffer it in the docs, I guess other Rx Implementations don't buffer it, which confused me.

For my particular use case I think I will just do a `publishValue()..connect();`, as the stream is supposed to live for the entire duration of the App and be initialized...

@brianegan I am getting an error while trying to run some tests, here's my code: ```dart static Stream _onAuthStateChangedOrReloaded = _mergeWithOnUserReloaded(_auth.onAuthStateChanged); static Stream _mergeWithOnUserReloaded(Stream stream) { return Rx.merge([stream, onUserReloaded]).publishValue()..connect(); }...

Thanks @hoc081098, but how can I use `emitsInOrder` with `expectAsync1`?

I tried this: ```dart test('Reloads emits the new User in onAuthStateChangedOrReloaded', () async { FirebaseUserReloader.onAuthStateChangedOrReloaded.listen(expectAsync1( (user) => expect(user, emitsInOrder([mockOldUser, mockNewUser])))); await FirebaseUserReloader.reloadCurrentUser(); }); ``` And I got this: ``` package:test_api...