wire

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: May 24, 2022 License: LGPL-2.1 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockups

func NewMockups() (*Wire, *Wire)

Types

type Flusher

type Flusher interface {
	Flush() error
}

type PipeConn

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

func (*PipeConn) Close

func (p *PipeConn) Close() error

func (*PipeConn) Read

func (c *PipeConn) Read(p []byte) (int, error)

func (*PipeConn) Write

func (c *PipeConn) Write(p []byte) (int, error)

type Wire

type Wire struct {
	Encoder *msgpack.Encoder
	Decoder *msgpack.Decoder

	Debug func(string)
	// contains filtered or unexported fields
}

Wire is the link with a client

func New

func New(conn io.ReadWriteCloser) *Wire

func (*Wire) Close

func (w *Wire) Close() error

func (*Wire) Flush

func (w *Wire) Flush() error

Jump to

Keyboard shortcuts

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