socket

package module

v0.0.0-...-b4f50ee Latest Latest Go to latest Published: Nov 25, 2019 License: MIT Imports: 6 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

net.Conn multiplexing.

multiplexing

import (
    socket "github.com/LiMoMoMo/go-multiplexingsocket"
)

2.get Socket use net.Conn init Socket

	socket := socket.NewSocket(cancel, ctx, conn)

	stream3, _ := socket.Register(3)

View Source

const (
	//LEN message prefix length
	LEN = 4
	//INTERVAL read step length
	INTERVAL = 1024
	//CHANNELSIZE size of channel
	CHANNELSIZE = 16
)

This section is empty.

This section is empty.

type Socket struct {
	Closef context.CancelFunc
	Ctx    context.Context
	//
	Conn net.Conn
	// contains filtered or unexported fields
}

Socket instance

func NewSocket(clf context.CancelFunc, ctx context.Context, conn net.Conn) *Socket

func (s *Socket) Register(streamid int) (*Stream, error)

Register stream_id & stream_handler

func (s *Socket) Start() error

Start running this socket

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

Stream instance

func (s *Stream) Read(data []byte) (n int, err error)

Read from stream

func (s *Stream) Write(data []byte) (n int, err error)

Write(b []byte) (n int, err error) Write to stream