pipe

package module

v0.0.2 Latest Latest Go to latest Published: Nov 2, 2025 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func SetStatusFunc(f StatusFunc)

type Conn struct {
	// contains filtered or unexported fields
}

func (c *Conn) Close() error

func (c *Conn) ID() string

func (c *Conn) IsClosed() bool

func (c *Conn) IsReady() bool

func (c *Conn) Read(p []byte) (n int, err error)

func (c *Conn) WaitClosed(ctx context.Context) error

WaitClosed blocks until the underlying connection has been closed or the provided context is canceled.

func (c *Conn) WaitReady(ctx context.Context) error

func (c *Conn) Write(p []byte) (n int, err error)

type Dialer interface {
	Dial(ctx context.Context, to string) (*Conn, error)
}

func CreateDialer(id string, sig signal.Signal) (Dialer, error)

type DialerFunc func(ctx context.Context, to string) (*Conn, error)

func (f DialerFunc) Dial(ctx context.Context, to string) (*Conn, error)

type Listener interface {
	Listen(ctx context.Context) (*Conn, error)
}

func CreateListener(id string, sig signal.Signal) (Listener, error)

type ListenerFunc func(ctx context.Context) (*Conn, error)

func (f ListenerFunc) Listen(ctx context.Context) (*Conn, error)

type StatusFunc func(conn *Conn, status webrtc.PeerConnectionState)

Path	Synopsis
signal
sse