stream

package

v0.6.2 Latest Latest Go to latest Published: Dec 9, 2020 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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

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

func NewServer(listenConfig stream.ListenConfig, handler stream.Handler, disconnectOnClose bool) (*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)