class EventMachine::Synchrony::TCPSocket

def receive_data(data) 

def receive_data(data)
  @in_buff << data
  if @in_req && (data = read_data)
    @in_req.succeed data unless data == :block
  end
end