feat(operators): startWithFuture

[Andrew-Bekhiet]

Adds a new operator that works like startWith but accepts a future

The whole idea is like this:

Stream.fromFuture(someFuture).switchMap((resolvedValue) => this.startWith(resolvedValue))

[hoc081098]

Is this operator necessary? I think using Rx.concat([future.asStream(), this]) is more idiomatic

[Andrew-Bekhiet]

I found myself repeating the implementation in my code so I wrote the extension and thought it might be useful for others too

Hmm yeah sure I think I just wrote the implementation that first came to my mind

[hoc081098]

@Andrew-Bekhiet.
It is not clear if we use it with broadcast stream, we can miss events before the future completes.
Either concat or concatEager is the best for all cases?

[Andrew-Bekhiet]

Sorry for being a little too late for this

Yes I think concatEager will be better so I changed the implementation

[hoc081098]

Sorry for being a little too late for this

Yes I think concatEager will be better so I changed the implementation

Thanks 👍
I will look at it