Documentation
¶
Overview ¶
Package streammanager keeps track of open streams and allows for reading/writing to them.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStreamManager ¶
func NewStreamManager() expreduceapi.StreamManager
NewStreamManager returns an object that can keep track of open streams.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.