streams

Documentation

Index

• type Connection
• type Stream
• type StreamHandler
• type StreamManger
  • func New(peer peer.Node, name string, path string) *StreamManger
  • func (s *StreamManger) Context() context.Context
  • func (s *StreamManger) Start(handler StreamHandler)
  • func (s *StreamManger) Stop()

Types

type Connection

type Connection interface {
	io.Closer
	network.ConnSecurity
	network.ConnMultiaddrs
}

type Stream

type Stream network.Stream

type StreamHandler

type StreamHandler func(Stream)

type StreamManger

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

func New

func New(peer peer.Node, name string, path string) *StreamManger

func (*StreamManger) Context

func (s *StreamManger) Context() context.Context

func (*StreamManger) Start

func (s *StreamManger) Start(handler StreamHandler)

func (*StreamManger) Stop

func (s *StreamManger) Stop()