PeerStreamer

    memcpy(ts_st->payload + ts_st->payload_index, buf, size);

    ts_st->payload_index += size;

    return 0;

}

            mpegts_write_pes(s, st, ts_st->payload, ts_st->payload_index,

                             ts_st->payload_pts, ts_st->payload_dts);

        }

    }

    put_flush_packet(s->pb);