stream

Documentation

Index

• func Forward[T any, A Stream[T], B Stream[T]](ctx context.Context, a A, b B) error
• func ForwardConn[T Stream[*pb.Frame]](ctx context.Context, stream T, conn net.Conn) error
• type Stream

Functions

func Forward

func Forward[T any, A Stream[T], B Stream[T]](ctx context.Context, a A, b B) error

func ForwardConn

func ForwardConn[T Stream[*pb.Frame]](ctx context.Context, stream T, conn net.Conn) error

Types

type Stream

type Stream[T any] interface {
	Send(T) error
	Recv() (T, error)
}