layerio

package module

v0.0.0-...-335a3b9 Latest Latest Go to latest Published: Apr 16, 2014 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type AsyncLayeredReader struct {
	sync.Mutex
	R io.ReadCloser
	W *io.PipeWriter
	// contains filtered or unexported fields
}

func NewAsyncLayeredReader(src io.ReadCloser) *AsyncLayeredReader

func (r *AsyncLayeredReader) Close() error

func (r *AsyncLayeredReader) Read(data []byte) (n int, err error)

type LayeredReadWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLayeredReadWriter(r io.ReadCloser, w io.WriteCloser) *LayeredReadWriter

func (c *LayeredReadWriter) EnableCompression() error

func (c *LayeredReadWriter) Read(p []byte) (n int, err error)

func (c *LayeredReadWriter) Write(p []byte) (n int, err error)