Передача вывода ffmpeg в ffplay stdin с повышением

Вместо того, чтобы выполнять рутинную работу вручную, вы можете просто прикрепить те же трубы:

bp::child ffmpeg(
    pg, bp::search_path(prod.cmd), bp::args(prod.args),
    bp::std_out > iso,
    bp::std_err > ise
);

bp::child ffplay(
    pg, bp::search_path(cons.cmd), bp::args(cons.args),
    (bp::std_in < iso)
    //, (bp::std_out> bp::null)
);

Это сделает то, что вы ожидаете. Это также означает, что вы не выбираете ipstream/opstream, потому что обе роли:

//bp::pstream iso, ise, in;
bp::pipe iso, ise, in;

Оба работают, но вам, вероятно, не нужна сложность объектов потока. На самом деле вы можете использовать асинхронные версии, и они все равно будут вести себя так же (но дадут вам больше возможностей/управления для асинхронного запуска):

Живая онлайн-демонстрация

С явно замененными/упрощенными командами для процессов производителя/потребителя:

Прямой эфир на Колиру

#include <boost/process.hpp>

namespace bp = boost::process;
using namespace std::chrono_literals;
using boost::system::error_code;

int main() {
    //bp::pstream iso, ise, in;
    bp::pipe iso, ise, in;
    //boost::asio::io_context io;
    //bp::async_pipe iso(io), ise(io), in(io);
    bp::group pg;

    struct { std::string cmd; std::vector<std::string> args; } tasks[] = {
#if 1
         { "bash", { "-c", "echo 'hello world'"} },
         { "rev", {} },
#else
         { "ffmpeg", {"-loglevel", "quiet", "-f", "pulse", "-i", "default", "-f", "wav", /*"-bitexact",*/ "-nostdin", "-"} },
         { "ffplay", {"-loglevel", "verbose", "-nodisp", "-f", "wav", "-i", "-"} },
#endif
    };

    auto& [prod, cons] = tasks;

    bp::child ffmpeg(
        pg, bp::search_path(prod.cmd), bp::args(prod.args),
        bp::std_out > iso,
        bp::std_err > ise
    );

    bp::child ffplay(
        pg, bp::search_path(cons.cmd), bp::args(cons.args),
        (bp::std_in < iso)
        //, (bp::std_out> bp::null)
    );

    if (!pg.wait_for(4s))
        pg.terminate();
}

Печатает обратную сторону «hello world», как и ожидалось:

dlrow olleh

Делать противно

Просто чтобы показать, вот как вы можете вручную сделать помпу внутрикостного введения.

Прямой эфир на Колиру

#include <boost/process.hpp>
#include <boost/asio.hpp>
#include <iostream>

namespace bp = boost::process;
using namespace std::chrono_literals;
using boost::system::error_code;

int main() {
    //bp::pstream iso, ise, in;
    //bp::pipe iso, ise, in;
    boost::asio::io_context io;
    bp::async_pipe iso(io), ise(io), in(io);
    bp::group pg;

    struct { std::string cmd; std::vector<std::string> args; } tasks[] = {
#if 1
         { "bash", { "-c", "echo -e 'hello world\\nYOHOHO\\nMOHOHO\\n'"} },
         { "xxd", {} },
#else
         { "ffmpeg", {"-loglevel", "quiet", "-f", "pulse", "-i", "default", "-f", "wav", /*"-bitexact",*/ "-nostdin", "-"} },
         { "ffplay", {"-loglevel", "verbose", "-nodisp", "-f", "wav", "-i", "-"} },
#endif
    };

    auto& [prod, cons] = tasks;

    bp::child ffmpeg(
        io, pg, bp::search_path(prod.cmd), bp::args(prod.args),
        bp::std_out > iso,
        bp::std_err > ise
    );

    bp::child ffplay(
        io, pg, bp::search_path(cons.cmd), bp::args(cons.args),
        (bp::std_in < in)
        //, (bp::std_out> bp::null)
    );

    std::function<void()> stream_pump;
    stream_pump = [&, buf=std::vector<char>(1024)]() mutable {
      boost::asio::async_read(iso, boost::asio::buffer(buf), [&](error_code ec, size_t const nread) {
        bool const eof = (ec == boost::asio::error::eof);
        std::cerr << "nread: " << nread << " (eof:" << eof << ")\n";
        if (ec && !eof)
          std::cerr << "async_read: " << ec.message() << " (" << nread << ")\n";
        else
          boost::asio::async_write(in, boost::asio::buffer(buf, nread),
            [=,&in,&stream_pump](error_code ec, size_t /*nwritten*/) {
              if (ec || eof) {
                std::cerr << "Closing in\n";
                in.close();
              }
              else
                stream_pump(); // continue the pump
          });
      });
    };

    stream_pump(); // prime the pump

    auto nhandlers = io.run_for(4s);
    std::cerr << "Handlers executed: " << nhandlers << "\n";
    ffmpeg.terminate();

    if (ffplay.running())
        ffplay.wait_for(1s);

    if (ffplay.running())
        pg.terminate();
}

Отпечатки

nread: 27 (eof:1)
Closing in
Handlers executed: 6

И дочерний процесс потребителя stdout содержит

00000000: 6865 6c6c 6f20 776f 726c 640a 594f 484f  hello world.YOHO
00000010: 484f 0a4d 4f48 4f48 4f0a 0a              HO.MOHOHO..