how to i take the first element fro ma flow and then consume the rest with collect ? seems like when...

# coroutines

[Nikky]

how to i take the first element fro ma flow and then consume the rest with collect ?
seems like when i use take it closes the flow

[louiscad]

withIndex + collect and destructuring

[Nikky]

ohh, smart

[Nikky]

that is a bit akward because i want to get the login info from the first websocket frame
and need to then use the security context for the rest of the code

[louiscad]

If you have a better idea about the API you want, I guess it's relatively easy to implement it yourself

[Nikky]

how can i implement taking one value out a flow without cancelling it ?
that seems to be the main issue..
and that spring + reactor types are involved possibly

[louiscad]

By using collect

[louiscad]

collect is the base of every flow operator

[louiscad]

You can also use shareIn or stateIn

[Nikky]

when i use shareIn i can then call first() and .skip(1).collect() later correct ?
or do i need to ensure it has a buffer for that ?

[louiscad]

It depends on the timing, but probably

[Nikky]

the first message should be there instantly.. the other ones could come later.. i will jsut try this

[Nikky]

this seemed to have worked, thx

[Dominaezzz]

Could always produceIn and receive() the items manually.

[louiscad]

Ah yes, very true, you can do something like that:

yourFlow.produceIn(someScope).consume {
    receive() // First value
    receiveAsFlow().collect { // Other values
    }
}