def __init__(self, stream, node=None):
        super(_StreamFork, self).__init__()
        self.stream = stream
        self.node = node
Creates a stream fork - class for building streams.
dataset/ETHPy150Open Stiivi/brewery/brewery/streams.py/_StreamFork.__init__