boost::asio::io_service ios;
	boost::asio::strand<boost::asio::executor> strand{ios.get_executor()};

	azmq::socket sb(ios, ZMQ_ROUTER);
	sb.bind(subj(BOOST_CURRENT_FUNCTION));

	azmq::socket sc(ios, ZMQ_DEALER);
	sc.connect(subj(BOOST_CURRENT_FUNCTION));

	//send coroutine task
	boost::asio::spawn(strand, [&](boost::asio::yield_context yield) {
		REQUIRE(strand.running_in_this_thread());
        boost::system::error_code ecc;
		auto const btc = azmq::async_send(sc, snd_bufs, yield[ecc]);
		REQUIRE(strand.running_in_this_thread());
        REQUIRE(!ecc);
		REQUIRE(btc == 4);
	});

	//receive coroutine task
	boost::asio::spawn(strand, [&](boost::asio::yield_context yield) {
		std::array<char, 5> ident;
		std::array<char, 2> a;
		std::array<char, 2> b;
x
		std::array<boost::asio::mutable_buffer, 3> rcv_bufs = { {boost::asio::buffer(ident),
						boost::asio::buffer(a),
						boost::asio::buffer(b)}};

		boost::system::error_code ecc;

		REQUIRE(strand.running_in_this_thread());
		auto const btb = azmq::async_receive(sb, rcv_bufs, yield[ecc]);
		REQUIRE(strand.running_in_this_thread());
		REQUIRE(!ecc);
		REQUIRE(btb == 9);

		REQUIRE(message_ref(snd_bufs.at(0)) == boost::string_ref(a.data(), 2));
		REQUIRE(message_ref(snd_bufs.at(1)) == boost::string_ref(b.data(), 2));
	});

	ios.run();