src/RSocketResponder.cpp
/// Handles a new Stream requested by the other end.
Handles a new Stream requested by the other end.
Handles a new Stream requested by the other end .
void RSocketResponder::handleRequestStreamCore(
    Payload request,
    StreamId streamId,
    const yarpl::Reference<yarpl::flowable::Subscriber<Payload>>&
    response) noexcept {
  auto flowable = handleRequestStream(std::move(request), std::move(streamId));
  flowable->subscribe(std::move(response));
}
void RSocketResponder :: handleRequestStreamCore ( Payload request , StreamId streamId , const yarpl :: Reference < yarpl :: flowable :: Subscriber < Payload > > & response ) noexcept { auto flowable = handleRequestStream ( std :: move ( request ) , std :: move ( streamId ) ) ; flowable -> subscribe ( std :: move ( response ) ) ; }
Handles a new Stream requested by the other end.
Handles a new Stream requested by the other end .