pipe: github.com/yaronsumel/pipe Index | Files | Directories

package pipe

import "github.com/yaronsumel/pipe"

Index

Package Files

pipe.go

Variables

var (
    Stdin  = os.Stdin
    Stdout = os.Stdout
    Stderr = os.Stderr
)

used here to prevent os package import

func AsyncRead Uses

func AsyncRead(pipe io.Reader, bufSize int, stdDataChan chan StdData)

AsyncRead keeps reading from io.reader into buffer return data in stdData structure use in only with routine - ie go AsyncRead

func IsNamedPipe Uses

func IsNamedPipe() bool

IsNamedPipe checks whether valid pipe used

func Read Uses

func Read(pipe io.Reader, bufSize int) ([]byte, error)

Read reads from io.reader one chunk as defined as bufSize

type StdData Uses

type StdData struct {
    Data []byte
    Err  error
}

StdData is used as channel structure

type StdDataChannel Uses

type StdDataChannel chan StdData

StdDataChannel used for as async communication channel

Directories

PathSynopsis
pipe-example

Package pipe imports 4 packages (graph) and is imported by 2 packages. Updated 2017-01-17. Refresh now. Tools for package owners.