Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncReader ¶
type AsyncReader[T any] struct { // contains filtered or unexported fields }
func NewAsyncReader ¶
func NewAsyncReader[T any](ch <-chan T) *AsyncReader[T]
func (*AsyncReader[T]) Read ¶
func (cr *AsyncReader[T]) Read() []T
type GobEncoder ¶
type GobEncoder struct{}
func (*GobEncoder) Decode ¶
func (g *GobEncoder) Decode(data []byte) (interface{}, error)
func (*GobEncoder) Encode ¶
func (g *GobEncoder) Encode(v interface{}) ([]byte, error)
Source Files
Click to show internal directories.
Click to hide internal directories.