filteredpipe

Documentation

Overview

Package filteredpipe provides pipes with interceptor for testing.

Index

• func Connect(conn0, conn1 io.ReadWriteCloser)
• func DetectAndClosePipe(h0, h1 func([]byte) bool) (io.ReadWriteCloser, io.ReadWriteCloser)
• func DetectAndDropPipe(h0, h1 func([]byte) bool) (io.ReadWriteCloser, io.ReadWriteCloser)

Functions

func Connect

func Connect(conn0, conn1 io.ReadWriteCloser)

Connect two io.ReadWriteCloser.

func DetectAndClosePipe

func DetectAndClosePipe(h0, h1 func([]byte) bool) (io.ReadWriteCloser, io.ReadWriteCloser)

DetectAndClosePipe creates pair of filtered pipe. Handler is called on each Write and determine to close the connection.

func DetectAndDropPipe

func DetectAndDropPipe(h0, h1 func([]byte) bool) (io.ReadWriteCloser, io.ReadWriteCloser)

DetectAndDropPipe creates pair of filtered pipe. Handler is called on each Write and determine to drop the remaining data.