class Async::IO::TCPSocket::StreamWrapper

def close
	@io.close
end

def flush
	@io.flush
end

def initialize(io)
	@io = io
end

def read(*args)
	@io.sysread(*args)
end

def sync= value
	@io.sync = value
end

def write(*args)
	@io.syswrite(*args)
end