multiplexer

Documentation

Index

• type Multiplexer
  • func NewMultiplexer(protocol string, conn net.Conn, isClient bool) (Multiplexer, error)
  • func NewSmux(conn net.Conn, isClient bool) (Multiplexer, error)
  • func NewYamux(conn net.Conn, isClient bool) (Multiplexer, error)
• type Smux
  • func (s *Smux) AcceptStream() (net.Conn, error)
  • func (s *Smux) OpenStream() (net.Conn, error)
• type Yamux
  • func (s *Yamux) AcceptStream() (net.Conn, error)
  • func (s *Yamux) OpenStream() (net.Conn, error)

Types

type Multiplexer

type Multiplexer interface {
	AcceptStream() (net.Conn, error)
	OpenStream() (net.Conn, error)
}

Multiplexer is the multiplexer interface

func NewMultiplexer

func NewMultiplexer(protocol string, conn net.Conn, isClient bool) (Multiplexer, error)

NewMultiplexer creates a multiplexer based on conf

func NewSmux

func NewSmux(conn net.Conn, isClient bool) (Multiplexer, error)

NewSmux creates a new smux multiplexer

func NewYamux

func NewYamux(conn net.Conn, isClient bool) (Multiplexer, error)

NewYamux creates a new yamux multiplexer

type Smux

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

Smux is the multiplexer using smux

func (*Smux) AcceptStream

func (s *Smux) AcceptStream() (net.Conn, error)

AcceptStream is used to block until the next available stream is ready to be accepted

func (*Smux) OpenStream

func (s *Smux) OpenStream() (net.Conn, error)

OpenStream is used to create a new stream

type Yamux

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

Yamux is the multiplexer using yamux

func (*Yamux) AcceptStream

func (s *Yamux) AcceptStream() (net.Conn, error)

AcceptStream is used to block until the next available stream is ready to be accepted

func (*Yamux) OpenStream

func (s *Yamux) OpenStream() (net.Conn, error)

OpenStream is used to create a new stream