rpc

Documentation

Overview

Package implements an internal mechanism to communicate with an impress terminal.

Index

• func WithoutFlush(w io.Writer) *withoutFlush
• func WithoutMutex() *withoutMutex
• type Pipe
  • func NewPipe(mutex mutexer, writer flushWriter, reader io.Reader) *Pipe
  • func (p *Pipe) Err() error
  • func (p *Pipe) Flush() *Pipe
  • func (p *Pipe) Get(variables ...interface{}) *Pipe
  • func (p *Pipe) Lock() *Pipe
  • func (p *Pipe) Put(values ...interface{}) *Pipe
  • func (p *Pipe) Sync() error
  • func (p *Pipe) Unlock() *Pipe

Functions

func WithoutFlush

func WithoutFlush(w io.Writer) *withoutFlush

func WithoutMutex

func WithoutMutex() *withoutMutex

Types

type Pipe

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

func NewPipe

func NewPipe(mutex mutexer, writer flushWriter, reader io.Reader) *Pipe

func (*Pipe) Err

func (p *Pipe) Err() error

func (*Pipe) Flush

func (p *Pipe) Flush() *Pipe

func (*Pipe) Get

func (p *Pipe) Get(variables ...interface{}) *Pipe

func (*Pipe) Lock

func (p *Pipe) Lock() *Pipe

func (*Pipe) Put

func (p *Pipe) Put(values ...interface{}) *Pipe

func (*Pipe) Sync

func (p *Pipe) Sync() error

func (*Pipe) Unlock

func (p *Pipe) Unlock() *Pipe