def put(self, obj):
        self.staging_buffer.append(obj)

        if self.is_full():
            self._flush()
Put data object into the pipe buffer. When buffer is full it is enqueued and receiving node
dataset/ETHPy150Open Stiivi/brewery/brewery/streams.py/Pipe.put