stream

Documentation

Index

• func GetRawStreamWithContext(ctx context.Context) (stream.Stream, bool)
• func NewServerWithConfig(conf *Config) (service.Service, error)
• type Config
• type Server
  • func NewServer(listenConfig stream.ListenConfig, handler stream.Handler, ...) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) ServeStream(ctx context.Context, stm stream.Stream)

Functions

func GetRawStreamWithContext

func GetRawStreamWithContext(ctx context.Context) (stream.Stream, bool)

func NewServerWithConfig

func NewServerWithConfig(conf *Config) (service.Service, error)

Types

type Config

type Config struct {
	Listener          stream.ListenConfig
	Handler           stream.Handler
	DisconnectOnClose bool `json:",omitempty"`
}

type Server

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

func NewServer

func NewServer(listenConfig stream.ListenConfig, handler stream.Handler, disconnectOnClose bool) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

func (*Server) ServeStream

func (s *Server) ServeStream(ctx context.Context, stm stream.Stream)