NewSubChain creates a new empty chain inheriting the properties of the parent chain Usefull for distribute/fanout building functions

This guy is how the value is supposed to be printed out (for a COPY command to PG).

* Example Decoder Usage decGenFn := func () interface{} { decoder := encoding.ProtobufGeneralDecoder() return func(in []byte) []<protobuf object> {

* Operator compatibility */

Init() bool //?? do we want this? Run runs the operation of the stream. It should never return before all the goroutines it started have quit It sho

Stop force a hard close of the stream. Look at HardStopChannelCloser for a possible implementation. Should be thread-safe Stop will only be called onc

*import ( "bytes" "encoding/gob" "log" )*/ import "log" import "github.com/cloudflare/go-stream/stream/encoding"

Create an empty multiset with default parameters. @TODO -- malloc's a pointer but doesn't free it. Must remember to free when done.

Hash a 4 byte fixed-size object.