Versions in this module Expand all Collapse all v1 v1.1.0 Feb 5, 2025 Changes in this version + const SocketReadDeadline + func CreateSocketReader(protocol string, addr string, port uint16) (io.ReadCloser, error) + func CreateSocketWriter(protocol string, addr string, port uint16) (io.WriteCloser, error) + func NewTCPSocketReader(addr string, port uint16) (io.ReadCloser, error) + func NewTCPSocketWriter(addr string, port uint16) (io.WriteCloser, error) + func NewUDPSocketReader(addr string, port uint16) (io.ReadCloser, error) + func NewUDPSocketWriter(addr string, port uint16) (io.WriteCloser, error) + type TCPTimeoutReader struct + Conns []*net.TCPConn + Listener *net.TCPListener + func (r *TCPTimeoutReader) Read(b []byte) (n int, err error) + func (r TCPTimeoutReader) Close() error + type UDPTimeoutReader struct + Conn *net.UDPConn + func (r UDPTimeoutReader) Close() error + func (r UDPTimeoutReader) Read(b []byte) (n int, err error)