+ if (event & yazpp_1::SOCKET_OBSERVE_READ)
+ {
+ m_data = true;
+ char buf[3];
+#ifdef WIN32
+ int r = recv(m_pipe.read_fd(), buf, 1, 0);
+#else
+ int r = read(m_pipe.read_fd(), buf, 1);
+#endif
+ if (r == -1)
+ {
+ std::cout << "Error read: "<< strerror(errno) << std::endl;
+ }
+ }
+ else if (event && yazpp_1::SOCKET_OBSERVE_TIMEOUT)
+ {
+ m_timeout = true;
+ m_obs->deleteObserver(this);
+ }