jsonstream

Documentation

Index

• type Formater
• type JSONStream
  • func New(out io.Writer, f ...Formater) *JSONStream
  • func (s *JSONStream) Close() error
  • func (s *JSONStream) Wait()
  • func (s *JSONStream) WriteObject(obj interface{}) error

Types

type Formater

type Formater interface {
	// BegineWrite write some datas at the stream beginning.
	BeginWrite() ([]byte, error)

	// EndWrite write some datas at the stream ending.
	EndWrite() ([]byte, error)

	// Write write a object be serialized.
	Write(o interface{}) ([]byte, error)
}

Formater define the data's format via stream transfer.

type JSONStream

type JSONStream struct {
	// contains filtered or unexported fields
}

JSONStream represents a stream transfer, the data be encoded with json.

func New

func New(out io.Writer, f ...Formater) *JSONStream

New creates a 'JSONStream' instance and use a goroutine to recv/send data.

func (*JSONStream) Close

func (s *JSONStream) Close() error

Close closes the stream transfer.

func (*JSONStream) Wait

func (s *JSONStream) Wait()

Wait waits the stream to finish.

func (*JSONStream) WriteObject

func (s *JSONStream) WriteObject(obj interface{}) error

WriteObject writes a object to client via stream tranfer.