stream

Documentation

Index

• Variables
• func NewReader(ctx context.Context, urlStr string) (nc.Subscriber, error)
• func NewWriter(ctx context.Context, urlStr string) (nc.Publisher, error)

Variables

var (
	ErrUndefinedStreamScheme = errors.New(`[stream] invalid scheme`)
)

Error list...

Functions

func NewReader

func NewReader(ctx context.Context, urlStr string) (nc.Subscriber, error)

NewReader stream

func NewWriter

func NewWriter(ctx context.Context, urlStr string) (nc.Publisher, error)

NewWriter publisher interface