The function definition for channel is this fn request_channel(&self, reqs: Flux<Result<Payload>>) -> Flux<Result<Payload>>
where flux is defined as Flux<T> = Pin<Box<dyn Send + Stream<Item = T>>>;
To request a channel it is required to put in a stream and get then a stream for receiving elements back.
When I want to send more elements after the first initial request to the rsocket server as far as I see this is not possible, due the variable is moved into the function and a clone is also not possible.
Expected have the possibility to add more elements to the request stream for a existing connection
The function definition for channel is this
fn request_channel(&self, reqs: Flux<Result<Payload>>) -> Flux<Result<Payload>>where flux is defined as
Flux<T> = Pin<Box<dyn Send + Stream<Item = T>>>;To request a channel it is required to put in a stream and get then a stream for receiving elements back.
When I want to send more elements after the first initial request to the rsocket server as far as I see this is not possible, due the variable is moved into the function and a clone is also not possible.
Expected have the possibility to add more elements to the request stream for a existing connection