utils

package
v0.0.0-...-04b2a96 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2014 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DecodeStream

func DecodeStream(dst io.Writer, src libswarm.Receiver, tag string) error

func EncodeStream

func EncodeStream(sender libswarm.Sender, reader io.Reader, tag string)

func Task

func Task(f func(in libswarm.Receiver, out libswarm.Sender)) libswarm.Sender

Types

type NopReceiver

type NopReceiver struct{}

func (NopReceiver) Receive

func (r NopReceiver) Receive(mode int) (*libswarm.Message, error)

func (NopReceiver) Unwrap

func (r NopReceiver) Unwrap() libchan.Receiver

type NopSender

type NopSender struct{}

func (NopSender) Close

func (s NopSender) Close() error

func (NopSender) Send

func (s NopSender) Send(msg *libswarm.Message) (libswarm.Receiver, error)

func (NopSender) Unwrap

func (s NopSender) Unwrap() libchan.Sender

type Tree

type Tree struct {
	*libswarm.Server
	// contains filtered or unexported fields
}

func NewTree

func NewTree() *Tree

func (*Tree) Bind

func (t *Tree) Bind(name string, dst libswarm.Sender) *Tree

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL