Versions in this module Expand all Collapse all v1 v1.1.0 Nov 23, 2015 v1.0.0 Dec 11, 2014 Changes in this version + func Distribute(input SimpleOutChannel, outputs ...SimpleInChannel) + func Multiplex(output SimpleInChannel, inputs ...SimpleOutChannel) + func Pipe(input SimpleOutChannel, output SimpleInChannel) + func Tee(input SimpleOutChannel, outputs ...SimpleInChannel) + func Unwrap(input SimpleOutChannel, output interface{}) + func WeakDistribute(input SimpleOutChannel, outputs ...SimpleInChannel) + func WeakMultiplex(output SimpleInChannel, inputs ...SimpleOutChannel) + func WeakPipe(input SimpleOutChannel, output SimpleInChannel) + func WeakTee(input SimpleOutChannel, outputs ...SimpleInChannel) + type BatchingChannel struct + func NewBatchingChannel(size BufferCap) *BatchingChannel + func (ch *BatchingChannel) Cap() BufferCap + func (ch *BatchingChannel) Close() + func (ch *BatchingChannel) In() chan<- interface{} + func (ch *BatchingChannel) Len() int + func (ch *BatchingChannel) Out() <-chan interface{} + type BlackHole struct + func NewBlackHole() *BlackHole + func (ch *BlackHole) Cap() BufferCap + func (ch *BlackHole) Close() + func (ch *BlackHole) In() chan<- interface{} + func (ch *BlackHole) Len() int + type Buffer interface + Cap func() BufferCap + Len func() int + type BufferCap int + const Infinity + const None + type Channel interface + type DeadChannel struct + func NewDeadChannel() DeadChannel + func (ch DeadChannel) Cap() BufferCap + func (ch DeadChannel) Close() + func (ch DeadChannel) In() chan<- interface{} + func (ch DeadChannel) Len() int + func (ch DeadChannel) Out() <-chan interface{} + type InChannel interface + type InfiniteChannel struct + func NewInfiniteChannel() *InfiniteChannel + func (ch *InfiniteChannel) Cap() BufferCap + func (ch *InfiniteChannel) Close() + func (ch *InfiniteChannel) In() chan<- interface{} + func (ch *InfiniteChannel) Len() int + func (ch *InfiniteChannel) Out() <-chan interface{} + type NativeChannel chan interface + func (ch NativeChannel) Cap() BufferCap + func (ch NativeChannel) Close() + func (ch NativeChannel) In() chan<- interface{} + func (ch NativeChannel) Len() int + func (ch NativeChannel) Out() <-chan interface{} + func NewNativeChannel(size BufferCap) NativeChannel + type NativeInChannel chan<- interface + func (ch NativeInChannel) Cap() BufferCap + func (ch NativeInChannel) Close() + func (ch NativeInChannel) In() chan<- interface{} + func (ch NativeInChannel) Len() int + type NativeOutChannel <-chan interface + func (ch NativeOutChannel) Cap() BufferCap + func (ch NativeOutChannel) Len() int + func (ch NativeOutChannel) Out() <-chan interface{} + type OutChannel interface + type OverflowingChannel struct + func NewOverflowingChannel(size BufferCap) *OverflowingChannel + func (ch *OverflowingChannel) Cap() BufferCap + func (ch *OverflowingChannel) Close() + func (ch *OverflowingChannel) In() chan<- interface{} + func (ch *OverflowingChannel) Len() int + func (ch *OverflowingChannel) Out() <-chan interface{} + type ResizableChannel struct + func NewResizableChannel() *ResizableChannel + func (ch *ResizableChannel) Cap() BufferCap + func (ch *ResizableChannel) Close() + func (ch *ResizableChannel) In() chan<- interface{} + func (ch *ResizableChannel) Len() int + func (ch *ResizableChannel) Out() <-chan interface{} + func (ch *ResizableChannel) Resize(newSize BufferCap) + type RingChannel struct + func NewRingChannel(size BufferCap) *RingChannel + func (ch *RingChannel) Cap() BufferCap + func (ch *RingChannel) Close() + func (ch *RingChannel) In() chan<- interface{} + func (ch *RingChannel) Len() int + func (ch *RingChannel) Out() <-chan interface{} + type SharedBuffer struct + func NewSharedBuffer(size BufferCap) *SharedBuffer + func (buf *SharedBuffer) Cap() BufferCap + func (buf *SharedBuffer) Close() + func (buf *SharedBuffer) Len() int + func (buf *SharedBuffer) NewChannel() SimpleChannel + type SimpleChannel interface + type SimpleInChannel interface + Close func() + In func() chan<- interface{} + type SimpleOutChannel interface + Out func() <-chan interface{} + func Wrap(ch interface{}) SimpleOutChannel
Go to main page