GoNetReader

package module
v0.0.0-...-4e1c24f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 19, 2022 License: BSD-2-Clause Imports: 6 Imported by: 2

README

GoNetReader

NetReader for net.Conn

Example:
Read:
func ConnectionRouter(Connection net.Conn) {
  reader := GoNetReader.NewNetReader()
  for {
    Pack, err := reader.NetRead(Connection)
      if err != nil {
	if err == io.EOF {
          Connection.Close() // EOF
        }
        continue 
      }
    //  ...
  }
  // ...
}
Write:
func Sender(Connection net.Conn) { 
  // ...
  _, connecterr := Connection.Write(GoNetReader.GetPackage(pack))
  // ...
}

Scheme:

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetPackage

func GetPackage(pack []byte) []byte

Types

type NetReader

type NetReader struct {
	BufScaner     *bufio.Scanner // Scanner
	NetBufChannel chan string    // Channel
	// contains filtered or unexported fields
}

func NewNetReader

func NewNetReader() *NetReader

func (*NetReader) FindPack

func (reader *NetReader) FindPack(data []byte, atEOF bool) (advance int, token []byte, err error)

func (*NetReader) FindPacksec

func (reader *NetReader) FindPacksec(data []byte, atEOF bool) (advance int, token []byte, err error)

func (*NetReader) NetRead

func (reader *NetReader) NetRead(Connection net.Conn) (string, error)

func (*NetReader) ReadPackage

func (reader *NetReader) ReadPackage() (string, error)

func (*NetReader) ReadWithoutEmpty

func (reader *NetReader) ReadWithoutEmpty(Wchannel chan string) (string, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL