cleanup
pipeline instead of go-blocks for responding to queries from client
pipeline and transducer instead of go-block for bringing together percolation matches and subscriptions
blocking pipeline and transducer instead of go-loop for finding percolation matches
cleanup