eventsmux

Documentation

Overview

Package eventsmux implements the events mux.

Index

• type Interface
  • func New(createSubs func(context.Context, func(error)) subscriptions.Interface) Interface

Types

type Interface

type Interface interface {
	// Requests returns the channel for requests.
	Requests() chan<- protocol.Request
	// Responses returns the channel for responses.
	Responses() <-chan protocol.Response

	// Run runs the events mux.
	Run(context.Context) error
}

Interface is the interface for the events mux.

func New

func New(createSubs func(context.Context, func(error)) subscriptions.Interface) Interface

New returns a new Interface.