Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrChanClosed = errors.New("close of closed portal.Chan")
ErrChanClosed is thrown in a panic if a Chan is closed more than once
Functions ¶
Types ¶
type Chan ¶
type Chan interface { Send() chan<- interface{} Recv() <-chan interface{} Close() }
Chan is a two-way channel
type Endpoint ¶
type Endpoint interface { Close() Done() <-chan struct{} Inbox() <-chan interface{} Outbox() chan<- interface{} }
Endpoint represents the different IO channels that a Protocol must manage
Click to show internal directories.
Click to hide internal directories.