나는 표준 : CIN에서 읽으려는 AsyncReadStream 스트림을 구현하기 위해 노력하고 지금까지 다음 코드가 있어요 MutableBufferSequence

Question

에 데이터를 작성하는 방법 :

template <class MutableBufferSequence, class ReadHandler> 
    void async_read_some(const MutableBufferSequence &buf, ReadHandler handler) { 

    char c[1024] = {}; 
    std::streamsize num = std::cin.readsome(c, 1023); 
    c[num] = 0; 

    boost::asio::streambuf buff(1023); 
    std::ostream os(&buff); 
    os << c; 

    // How do I get the buff into the buf???? I've tried below: 
    //boost::asio::buffered_stream<boost::asio::streambuf> buff_stream(buff); 
    //boost::asio::read(buff_stream, buf); 
    handler(boost::system::error_code(), boost::asio::buffer_size(buf)); 
    } 

내가 알고 있어요을 코드의 일부가 위의 경우 차단하고 있습니다. 실제로는 없어야하지만 내 문제 외에도 있습니다 (제 생각에). MutableBufferSequence http://www.boost.org/doc/libs/1_41_0/doc/html/boost_asio/reference/MutableBufferSequence.html에 대한 설명서를 확인했으며이를 수행 할 분명한 방법이없는 것 같습니다. 분명히 나는 ​​뭔가를 과감하게 오해하고 있습니다.

Answer 1

나는 streambuf의를 건너 뛸 것 (두 번 복사 이유는 무엇입니까?).

template <class MutableBufferSequence, class ReadHandler> 
void my_read_some(MutableBufferSequence buf, ReadHandler handler) { 

    char tmp[1024] = {}; 

    std::cin.read(tmp, sizeof(tmp)); 
    std::streamsize num = std::cin.gcount(); 

    if(std::cin || num) { 
     ba::buffer_copy(buf, ba::buffer(tmp, num)); 

     handler({}, num); 
    } else { 
     handler(ba::error::eof, num); 
    } 
} 

( ba::는 boost::asio::을 abbreviates 임).

참고 또한 read_some은 (std::cin.readsome always reading 0 bytes) 원하지 않는 것 같다.

는이 기능을 사용하려면

int main() { 
    std::array<char, 512> block1{}, block2{}; 
    std::vector<ba::mutable_buffers_1> blocks { ba::buffer(block1), ba::buffer(block2) }; 

    auto handler = [&blocks](boost::system::error_code ec, size_t transferred) { 
     if (ec) 
      std::cout << "Error " << ec.message() << "\n"; 
     else { 
      std::cout << "Received " << transferred << " bytes\n-------\n"; 

      std::copy_n(ba::buffers_begin(blocks), transferred, std::ostreambuf_iterator<char>(std::cout)); 
      std::cout << "\n-------\n"; 
     } 
    }; 

    my_read_some(blocks, handler); 
} 

그것이 Live On Coliru