grpcx

Documentation

Index

• type IOStream
• type IOStreamWrapper
  • func NewIOStreamWrapper(stream IOStream) *IOStreamWrapper
  • func (iw *IOStreamWrapper) Close() error
  • func (iw *IOStreamWrapper) Read(p []byte) (n int, err error)
  • func (iw *IOStreamWrapper) Wait()
  • func (iw *IOStreamWrapper) Write(p []byte) (n int, err error)

Types

type IOStream

type IOStream interface {
	Recv() (*proto.IOStreamData, error)
	Send(*proto.IOStreamData) error
	Context() context.Context
}

type IOStreamWrapper

type IOStreamWrapper struct {
	IOStream
	// contains filtered or unexported fields
}

func NewIOStreamWrapper

func NewIOStreamWrapper(stream IOStream) *IOStreamWrapper

func (*IOStreamWrapper) Close

func (iw *IOStreamWrapper) Close() error

func (*IOStreamWrapper) Read

func (iw *IOStreamWrapper) Read(p []byte) (n int, err error)

func (*IOStreamWrapper) Wait

func (iw *IOStreamWrapper) Wait()

func (*IOStreamWrapper) Write

func (iw *IOStreamWrapper) Write(p []byte) (n int, err error)